我想要处理数据流,并需要显示处理后的数据接近实时。为此,我创建了一个hub类。
public class AzureGuidanceEventHubReceiver : Hub
{
EventProcessorHost eventProcessorHost;
public async void ProcessEvents()
{
//Do some code here
eventProcessorHost.RegisterEventProcessorAsync<SimpleE
我正在尝试使用EventProcessorHost来使用JAVA中的eventhub的消息。下面的步骤给出了和,但是当我运行代码时,我会出现以下错误。
Registering host named <name>
Failure while registering: java.util.concurrent.ExecutionException: com.microsoft.azure.storage.StorageException: The client could not finish the operation within specified maximum exec
我有一个晚上,我正在发送数据给它。现在我需要收到这些数据。因此,我遵循了这篇教程的文章。
“在Java中使用EventProcessorHost接收消息”
在所有的类中,它都不允许我@重写。它给了我以下错误。
Multiple markers at this line
- implements com.microsoft.azure.eventprocessorhost.IEventProcessor.onOpen
- The method onOpen(PartitionContext) of type EventProcessor must override a superclass
我正忙着为azure EventBus客户端实现一个EventProcessorHost客户端。
我有一个实现IEventProcessor的类,如下所示:
public class MyEventProcessor : IEventProcessor
{
Stopwatch checkpointStopWatch;
//TODO: get provider id from parent class
public async Task CloseAsync(PartitionContext con
我希望得到一些关于如何在工作角色中使用EventProcessorHost的指导。基本上,我希望EventProcessorHost并行地处理分区,我想知道我应该把这种类型的代码放在worker角色中,以及我是否遗漏了任何键。
var manager = NamespaceManager.CreateFromConnectionString(connectionString);
var desc = manager.CreateEventHubIfNotExistsAsync(path).Result;
var client = Microsoft.ServiceBus
我对使用EventProcessorHost和IEventProcessor非常陌生,我正在尝试弄清楚如何从EventProcessorClass中获取数据。如果我只想把新的消息记录到控制台上,我现在已经把一切都准备好了。 我目前的实现(我甚至不确定它是否是可接受的,甚至是好的实践)创建了一个静态变量,然后在数据传入时将其存储在其中,以便另一个处理器可以收集它。这样做可以吗?或者有没有更好、更干净的方式来访问数据? 这就是我到目前为止所拥有的(锁定机制是非常基本的,当我让其余的代码工作时,它将被修复): internal class Receiver
{
public static
我有一个简单的EventHub侦听器示例代码试图侦听事件集线器
public class Program
{
private const string EventHubConnectionString = "Endpoint=sb://fake.servicebus.windows.net/;SharedAccessKeyName=SendETB;SharedAccessKey=JcvVeX5KsGHfJkPNmdns5jvNYVpB9Wc05jDuMaV3NW8=";
private const string EventHubName = "my
试图在Windows中实例化Microsoft.Azure.EventHubs EventProcessorHost将导致以下异常:
Service cannot be started.
Microsoft.Azure.EventHubs.Processor.EventProcessorRuntimeException:
Out of retries creating lease for partition --->
...
System.InvalidOperationException:
This implementation is not part of the Windows