azure-eventhub相关内容

将两个分区流合并为一个流

我是Azure事件中心的新手.通过事件中心，我们从IoT设备接收数据，并通过分配分区号"0"和"1"将数据分为两个流. 我们之所以需要两个数据流，是因为一个数据流需要训练“深度学习模型"，而另一个数据流需要使​​用另一端的新数据来测试我们训练的模型. 这称为“在线学习". 但是，在尚无训练模型的情况下，我们无法使用该模型对其进行测试，因此，在这种情况下，我希望将两个分区的流合并为 ..
发布时间：2020-09-17 03:58:11 其他开发

我们可以作为Azure事件中心/通知中心的订阅者订阅电子邮件ID或单元号吗?

在我的python应用程序中，如果发生任何不良事件/好事件，我想将事件详细信息作为通知消息发送到已订阅此应用程序的用户的电子邮件地址或电话号码.因此，我正在寻找发布者-订阅者模型的天蓝色云 看起来有多个Azure服务实现了相似的目标，但差异很小.事件中心和通知中心似乎很有希望.所以我的问题如下: 是否可以将电子邮件ID/电话号码订阅到Azure事件中心，并接收正在发送/产生到Azure ..
发布时间：2020-09-17 03:57:08 其他开发

如何在AzureStorageCheckpointLeaseManager类中提供容器的完整路径

我正在使用Azure python SDK的EPH(EventProcessorHost)类从eventhub接收事件. 实际上，它使用AzureStorageCheckpointLeaseManager在存储帐户中进行检查点和分区.但是我看不到在哪里可以写存储帐户的完整路径.像它一样直接在存储帐户的指定容器内创建文件.我想提供容器内的完整路径.我在哪里可以做? 解决方案 这是我的研究 ..
发布时间：2020-09-17 03:57:05 Python

如何仅在事件中心接收最新数据

在eventhub中，我同时具有“发送者"和“接收者"脚本，用于这两个脚本之间的通信. 我面临的问题是，似乎我收到的是昨天发送的数据集以及刚刚发送的数据集.我正在尝试通过时间段或事件数来控制数据量. sender.py的基本代码如下: CONSUMER_GROUP = "$default" OFFSET = Offset("-1") PARTITION = "0" total ..
发布时间：2020-09-17 03:56:02 Python

将数据从函数，事件中心，Azure数据资源管理器中提取?

我有一些JSON数据进入IOT集线器，然后它触发了取消嵌套数据的功能. 该函数将此数据发送到事件中心，然后应该由Azure Data Explorer根据我设置的映射来摄取数据. 问题在于没有数据可以发送到数据浏览器；它将通过映射接收数据的唯一方法是将源设置为通过自定义路由接收信息的事件中心. 是否可以通过IOT集线器->功能->事件集线器在数据资源管理器中提取数据? 编辑 ..
发布时间：2020-09-17 03:55:57 其他开发

如何使用python在EventHub消息中发送属性详细信息?

我指的是本文" 消息具有以下组件:偏移量，正文，systemProperties，属性. 偏移量是自动生成的，但我们可以提供另一个. 对于我的项目-除了消息正文外，我还需要发送不属于正文一部分的"Properties"，该怎么做?我检查了类EventData(object):看起来application_properties可以用于执行此操作，但是我不确定如何实现. applicat ..
发布时间：2020-09-17 03:54:54 Python

在获取数据Spring-Cloud-Stream Kafka Azure事件中心时出现意外错误代码13-

自12月18日以来，此问题突然弹出，一切正常，找不到任何线索，这个异常情况在经过6个月的正常工作后突然不断出现. 我无法在本地独立环境中进行复制，但是它出现在具有微服务的docker映像中，其中之一与 Azure even hub 进行通信. > 我已经搜索并找到了发布.在这篇文章中，我也遇到了同样的问题，但是找不到任何解决方法或线索，所以我发布了这个问题. 请参考下面的堆栈跟踪: ..
发布时间：2020-09-17 03:54:51 其他开发

是否保证序列号将增加1 EventHub?

我使用Java中的PartitionReceiver类从单个Azure EventHub分区中消费.我试图了解我收到的每个EventData对象中可用的x-opt-sequence-number SystemProperty. 保证每个消费的EventData序列号增加1，并且分区中存在每个可能的序列号吗?例如，如果我使用了一个序列号为5的事件，另一个使用了序列号为10的事件，则基于此必须存 ..
发布时间：2020-09-17 03:53:45 其他开发

如何获取Event Hub Azure的Bearer令牌

我已经在Microsoft Azure中创建了事件中心，我正在尝试执行GET操作来获取有关以下文档的事件中心的详细信息:- https://docs.microsoft.com/zh-cn/rest/api/eventhub/eventhubs/get ，但我需要"Bearer Token"在POSTMAN中获取结果，如何获取令牌?详细的解释将不胜感激 解决方案 请遵循 然后将事件中心资源 ..
发布时间：2020-09-17 03:51:40 其他开发

调用Azure Event Hub并遇到连接错误时客户端挂起

我想将事件消息发送到Azure事件中心.我注意到如果我配置不当，那么我的应用会挂起并且不会终止. 我编写了一个非常简单的Java类，尝试将事件消息发送到事件中心.如果我输错了事件中心的端点，则该应用程序将挂起.真令人失望. 我可能会误解某些事情，但是我想做的只是发送一条简单的消息，仅此而已.我该怎么办? ConnectionStringBuilder connectionSt ..
发布时间：2020-09-17 03:51:39 Java开发

当Azure事件中心中的一个分区处于活动状态时，如何禁用其他分区以停止接收消息

我有一个安装在3台不同服务器上的应用程序.该应用程序订阅一个Event Hub.该事件中心有8个分区.因此，当我在所有3台计算机上启动应用程序时，所有3台计算机上的所有分区都是随机初始化的. 说像这样: VM1:分区0,1,2 VM2:分区3,4 VM3:分区5,6,7 所有这些分区都在连续接收消息.这些消息需要一个接一个地处理.现在，我的要求是，在一台机器/服务器中，我一次 ..
发布时间：2020-09-17 03:51:34 C#/.NET

Azure事件处理器主机Java库-ReceiverRuntimeInformation在分区上没有实际统计信息

我试图通过利用PartitionContext在接收到事件时提供的ReceiverRuntimeInformation对象来获取最后排队的序列号，以在消费者端跟踪消费者和生产者之间的滞后.但是，ReceiverRuntimeInformation对象没有与事件中心的特定分区相关的更新值，它返回0.示例代码和日志输出如下: public class EventProcessor extends ..
发布时间：2020-09-17 03:51:31 其他开发

没有传入消息到事件中心

无法看到来自Azure AD日志的传入消息进入Azure Event Hub.我关注了以下文章. https://docs.microsoft.com/zh-CN/azure/active-directory/reports-monitoring/tutorial-azure-monitor-stream-logs-to-event-hub 有人可以让我知道我是否想念这里. 下面 ..
发布时间：2020-09-17 03:51:27 其他开发

Eventhub读取数据作为python中的列表

我想将Azure Eventhub用作中间件消息传递队列.我基本上是以列表格式发送模拟数据，现在以字符串格式接收它. 您可以看到这是我现在正在处理的代码.我正在尝试对下面的行进行处理，以浮动形式累积在列表中的每个事件数据. LIST.append(event_data.message._body) 这是我的代码的主体. CONSUMER_GROUP = "$default" ..
发布时间：2020-09-17 03:50:23 Python

订阅Azure云合作伙伴门户

我正在尝试自动化Azure云合作伙伴门户上的商品发布过程. 当报价到达预览阶段时，我想收到通知. 一种实现方法是部署无服务器功能，该功能会轮询cloudpartner api以检查报价的状态. 我想知道是否有一个更干净的解决方案来解决这个问题. 我已经在以下页面上阅读了有关事件网格的信息: https://docs.microsoft.com/en-us/azure/事件网格/概述 ..
发布时间：2020-09-17 03:50:19 其他开发