azure-eventhub相关内容

如何在Azure Iot-hub中为Twin Change实施路由功能?

我已经设置了用于更新twin的路由,并选择了端点作为Iot集线器支持的事件(默认),但是它不起作用. 这里是屏幕截图 我做错了什么或缺少什么吗? 任何建议或对其他材料的引用将不胜感激. 解决方案 最后,我得到了解决方案,我只是切换到另一个帐户,并从头开始设置了一切,所以效果很好. 我注意到的唯一区别是我在旧帐户 WEST US 中的位置和新帐户在 CENTRAL US 中 ..
发布时间:2020-09-17 03:50:12 其他开发

将消息定向到消费者

我的客户端正在尝试向接收者发送消息.但是我注意到接收器有时不能接收到客户端发送的所有消息,因此丢失了一些消息(不确定问题出在哪里?客户端还是接收器). 关于为什么可能会发生的任何建议.这是我目前正在做的 在接收方,这就是我正在做的. 这是事件处理器 async Task IEventProcessor.ProcessEventsAsync(PartitionCon ..
发布时间:2020-09-17 03:49:04 C#/.NET

获取“远程主机强行关闭了现有连接."来自Azure

尝试遵循Microsoft Azure的“事件中心入门"示例( 由于这是在尝试连接到Azure时,并且在Azure门户中一切似乎都已就绪(按照上述示例),所以我陷入了困境. 我将西欧地区用作我的活动中心. 解决方案 您想尝试的事情: 确保您的连接字符串为connect. 尝试对连接字符串中的主机部分执行ping操作. 检查防火墙. 检查您是否确实发送了一些消息,并且是否 ..
发布时间:2020-09-17 03:48:02 其他开发

哪种消息传递服务可与Azure功能扇出模式一起使用而无扇出功能?

我们是Azure消息服务和功能的新手,我们了解了不同消息服务的基本概念,例如存储队列,服务总线队列,服务总线主题和事件中心,我们还阅读了扇出模式由Microsoft提供,但是其工作方式更像是扇出,然后是扇回,这意味着在扇出过程中,当前功能仍会保留在那里,直到所有资源扇回为止. 一种简单的情况是,我们将对象保存在 azure函数启动器中,并成功保存到存储中后,我们想向实施的3个不同的目的地/消 ..

所有实例均未在Azure App Service中运行

我正在使用Azure应用服务,该服务承载使用EventProcessorHost从事件中心读取数据的应用程序.我已经分配了6个实例(手动缩放)来运行.我检查了App Service中的指标( CPU时间),发现只有5个实例正在运行. 我得到了不同的实例来计算不同的指标. 数据输入指标显示6个实例,而 CPU时间指标显示5个实例.我很迷惑.请提出建议. 解决方案 AlwaysOn功能用 ..

Microsoft Azure服务总线/事件中心:没有消息,只有请求

我正在通过HTTP POST向我的Azure Event Hub发送消息(以与IoT Hub和Blob存储一起使用). 这些是HTTP调用的设置: 每次发送消息时,我都会收到请求,但没有消息. 我尝试过: 不同的SAS密钥和所有者 不同的标题,也没有标题 我找到此问题. 我还确保按照那里的建议检查权限,但是已经将它们设置为必要的级别. 值得注意的是:由于某种原 ..
发布时间:2020-09-17 03:47:51 其他开发

Azure功能的事件中心输入绑定

我有一个Azure函数,其输入绑定到事件中心. public static async Task Run(TraceWriter log, string eventHubMessage) 该功能被触发时,默认情况下每次执行会收到多少条消息? 是1次执行= 1条消息吗? 我已阅读文档并了解您可以在函数的host.json文件中设置以下属性: "eventHub": { ..
发布时间:2020-09-17 03:47:47 C#/.NET

来自Azure IOT中心的SMS消息传递

我当前正在使用Adruino Uno构建一个项目,以收集温度和湿度等天气数据,然后将这些数据传递到Azure IOT中心,然后将消息处理并再次存储到Azure中的SQL数据库中.最后,数据将显示在网站上,用户可以注册并查看我收集的天气数据. 我正在尝试在系统中实施SMS通知,以便如果温度达到某个特定阈值(例如0摄氏度),系统上的用户将收到SMS消息,通知他们低温. 我的问题是,SMS消 ..

如何使用Azure EventHub触发函数返回到检查点?

我有一个使用Azure Functions应用实现的EventHub触发器.我的业务逻辑实现在该功能上是错误的,因此必须对其进行纠正.我已经更正了我在Functions App上的实现,如何将检查点更改为该Azure Function追溯到24小时并使流数据可供Functions App使用? 解决方案 当我需要从头开始处理集线器中的事件时,我去了Blob Storage-> azure- ..
发布时间:2020-09-17 03:46:43 其他开发

我可以更改Azure Function Event Hub触发器启动检查点吗?

当我站起来一个新的Azure Function来监听我们的事件中心时,有了一个新的消费者组,它会获得所有发送到事件中心的消息,即使是几个月前也是如此.我认为将集线器上的邮件保留时间设置为一天会限制该时间,但显然没有限制.无论如何,我真的只希望新的Azure Function从初始部署或测试点开始接收事件,但是我不知道如何指定该初始开始检查点,因为AF将这些东西神奇地存储在存储中. 如果我手动执行 ..
发布时间:2020-09-17 03:46:36 其他开发

将多个Azure EventHub触发器触发到Azure Function应用中的单个函数

我想从两个不同的eventhub中执行相同的功能(基于消息数据的更改很少). 是否可以将两个使用者组附加到一个功能上. 即使将其添加到function.json,它也无法正常工作. 解决方案 简短的回答是“否".您不能将多个输入触发器绑定到同一函数: https://github.com/Azure/azure-webjobs- sdk-script/wiki/function ..
发布时间:2020-09-17 03:46:34 其他开发

Azure Event Hub超时

当尝试向Azure事件中心发送消息时,我有时会在事件中心客户端中看到超时错误.客户端似乎已达到资源限制,但是我不确定... 这里的代码: MessagingFactory messagingFactory = null; EventHubClient hubClient = null; try { ..
发布时间:2020-09-17 03:45:32 C#/.NET

与Azure事件中心通信时发生EPOCH错误

我正在使用Azure Event Hub监听应用程序中的实时数据.在大多数情况下,它工作正常,但有时会引发以下错误- 创建新的接收器,其具有较高的"3109"纪元,因此当前具有"3108"纪元的接收机已断开连接.如果要重新创建接收器,请确保使用更高的纪元. TrackingId:eb2a6f970000494500f379f85b484a9f_C-1553490498_B22,SystemT ..
发布时间:2020-09-17 03:45:28 其他开发

发送到Microsoft Azure EventHubs时如何使用客户端事件批处理功能

我正在处理EventHub的高吞吐量应用程序.根据文档,要从单个发件人获得非常高的吞吐量,则需要客户端批处理(每个事件不得超过256 KB限制). 使用Service Bus代理消息传递提高性能的最佳做法建议通过客户端批处理来提高性能.它描述了可用于队列或主题客户端的客户端批处理,这可以将消息的发送延迟一定的时间,然后以单个批处理的方式传输消息. EventHub客户端中可以进行客户端 ..
发布时间:2020-09-17 03:45:27 其他开发

Azure函数的多个触发器

我们有一个带有事件中心触发器的Azure功能.同一Azure功能是否可以在多个事件中心上触发? 解决方案 否,目前不支持此方案. 从评论中(Ling Toh 17年1月18日在18:23): 没有计划为每个功能支持多个触发器.您将必须为每个EventHub创建一个Function.如果在功能之间可以共享通用代码,则可以将它们移到可以从每个功能调用的辅助方法中. ..
发布时间:2020-09-17 03:44:21 其他开发