0

在连续网络作业中接收事件数据时,我遇到了问题。

我正在使用设备客户端的批处理异步方法发送消息。在网络工作中,我一个接一个地收到这些批次。当第一批到达时,直到其中的所有消息完成;下一批不会触发并执行。在第一批执行完成后,只有第二批触发并开始执行。

我希望它并行执行。

我在接收方使用事件处理器主机,在发送方使用设备客户端。

我是否缺少任何配置选项?就像在队列中一样,有一个称为批量大小的选项,用于定义要并行处理的消息数量。那么,在连续网络作业中是否有任何选项,即分批接收事件中心数据并并行运行这些批次?

4

1 回答 1

0

我在逐行检查我的代码后得到了答案。在调用 EventProcessorHost 的构造函数时缺少一个参数:leaseContainerName。

解决方案是使用这个:

public EventProcessorHost(string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName, string leaseBlobPrefix = null);

以前我用这个:

public EventProcessorHost(string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString);

供参考检查此链接: https ://developers.de/blogs/damir_dobric/archive/2016/09/12/how-to-configure-eventprocessorhost-for-iothub.aspx

于 2018-01-10T13:38:42.297 回答