Microsoft Azure EventHubs是Azure云中高度可扩展的高吞吐量低延迟持久事件摄取系统。 EventHubs用作应用程序处理具有可变负载配置文件的事件的事件缓冲区。 Microsoft Azure Event Hubs与Apache Kafka或AWS Kinesis相当。这是由Microsoft团队构建和运行的完全托管服务产品。
我正在将大量事件(每秒超过1000个)从多个传感器传递到单个事件中心。在将数据从传感器传递到事件中心时,我无法访问传感器ID,因此我只能...
要设计一种系统,其中许多传感器会将数据传输到事件中心。每个传感器每秒将传输大量数据(最大15-20(约5 KB))。一种用例是所有这些...
Azure EventProcessor如何访问SignalR HubContext?
我有一个.net core 3.0 Web应用程序。在Startup.cs中,我注册了一个EventProcessor(来自Microsoft.Azure.EventHubs.Processor),该事件侦听Azure EventHub中的事件。我是这样的:await ...
如何在AzureStorageCheckpointLeaseManager类中提供容器的完整路径
我正在使用Azure python SDK的EPH(EventProcessorHost)类从eventhub接收事件。它实际上使用AzureStorageCheckpointLeaseManager在...
无法从Azure eventHub将数据保存在cosmosDB上,仅获取请求而不是消息
我正在尝试通过Azure从物联网设备接收和保存数据,我不明白问题所在,但是我只是在事件中心收到请求,而没有消息,因此在cosmosDB上什么也没有保存,...
我正在运行一个设置,其中Stream Analytics作业正在从Azure Event Hub读取。事件中心包含在名称空间中,并且专门为SA创建了使用者组。最近我...
我正在使用eventhub摄取很多事件。我有多个使用者正在运行一个扩展组,它从具有多个分区的eventhub中读取这些事件。我要去...
我想使用python客户端在事件中心发送一批具有不同分区键的事件。我可以发送带有分区键集的单个消息,但是如果我需要发送一批...
Azure Event Hubs to Databricks,正在使用的数据帧发生了什么
我一直在使用Pyspark在Azure事件中心上开发概念证明,将JSON数据流传输到Azure Databricks Notebook。在我看到的示例中,我创建了如下粗略的代码,采用...
使用Azure EventHubs Capture生成的Azure Data Lake Gen1中的Databricks读取avro数据失败
我正在尝试从Azure Data Lake Gen1读取avro数据,该数据是从Azure EventHubs生成的,并在pyspark中启用了Azure Databricks中的Azure Event Hubs Capture:inputdata =“ evenhubscapturepath / * / *” ...
Azure EventHub EnqueuedTime是否在分区内单调增加?
Microsoft Azure EventHubs EnqueueTime是否实现为Lamport时间戳?确保其在单个分区中单调递增?我所追求的是, 是否可以按事件的顺序对事件进行排序...
我在这个主题上找不到太多资料,但是我正在将一个对象序列化到Avro,然后发送到Azure EventHub。。我认为Avro也需要包含架构。 ....
EventProcessorHost方法-我需要事件中心的天蓝色blob存储和租用容器吗?
我正在使用Microsoft.Azure.EventHubs.Processor库中的EventProcessorHost()方法,似乎除了事件中心库外,我还需要指定一个存储连接字符串和一个...
Azure Event Hub使用文档中描述的分区使用者模式。在实际场景中,我在理解此模型的消费者方面有一些问题。所以说我...
我的客户端正在尝试向接收者发送消息。但是我注意到接收器有时没有收到客户端发送的所有消息,因此丢失了一些消息(不确定...
我的客户端正在尝试向接收者发送消息。但是我注意到接收器有时没有收到客户端发送的所有消息,因此丢失了一些消息(不确定...
我是Azure事件中心的新手。通过事件中心,我们从IoT设备接收数据,并通过分配分区号“ 0”和“ 1”将数据分为两个流。我们之所以需要两个...
在Azure Event Hub Capture中,尽管捕获的邮件指标与传入的消息匹配,但捕获积压总是很高。我们如何推断呢?这是否表示Azure正在删除邮件...
使用新的.NET SDK Azure.Messaging.EventHubs与EventProcessorClient进行检查点
如何使用新的Azure SDK在特定时间或指定数量的事件之后定期保存检查点?该示例仅使用一个“ InMemoryPartitionManager”,它不保存当前的...
是否可以使用Python从EventHub中接收方停止的位置继续读取?
我正在使用azure-eventhub官方lib从EventHub的主题中读取事件。我希望当接收器停止读取时,EventHub能够保持接收器组的最后一个偏移量,因此...