Azure函数+ EventHub:为什么批处理潜伏期不断成长?
我有下一个图表: 您可以看到我的批处理潜伏期成长,并且传出消息的数量增长 向下。 在功能内部,我确实附加到斑点存储。但是Blob指标说一切都还好。 …
建立Azureeventhub& Azurekubernetes
我有Azureeventhub设置,并为选定的网络打开了它,这意味着只有白色的IP可以访问。 另一方面,我将Azurekubernetesservice配置为读取来自Azureeventhu…
MS Graph API:订阅Azure Event Hub的组上的通知
基本上,我试图订阅有关组更改的通知,以便在第三方系统中调整授权,请在下面找到代码。它使用Java的Graph SDK。我添加了我遵循的文档以供参考,请参…
Azure功能输出到EventHub
我有一个使用nodejs构建的Azure函数,该功能在HTTP触发器上接收数据,处理数据,然后必须将处理的数据输出到Azure事件中心,以在Azure ADX中摄入。输…
Azure apim将日志发送到EventHub(选择的WebSocketConnection)。如何设置它?
我正在使用连接的后端API(应用程序服务)的一个APIM资源。这是我为阅读EventHub的数据所做的整个设置,该数据是通过APIM从应用程序服务发送的。 设置…
Docker以及Kubernetes的EventHub连接问题
我有一个使用C#的Confluent Kafka库的代码。 我能够正确从本地系统连接到Azure事件中心。 但是,当我将其放在容器中时。我会收到以下错误。 3|165640…
通过CSV文件,通过KAFKA API将数据从Azure Databricks流到Azure事件中心
我是Azure Databricks和Event Hubs的新手。我一直在努力使用SPARK和KAFKA API将数据从Databrick流传输到事件中心。我想要流的数据在.CSV文件中。流启…
使用Spring Cloud Stream模拟Azure事件集线器上的生产者错误
我正在使用下面的春季云流kafka活页夹的生产者和消费者是我的生产者配置,我想在将消息发送到EventHub并将其引导到错误频道时会收到错误。不确定事件…
在Azure EventHub或Azure功能中为传入数据创建警报
我想创建一个警报,如果在过去6小时内未收到EventHubs(或Azure功能)的特定数据(例如:我将每天收到学生的信息到我的EventHubs,如果我没有收到有关…
无法诊断为什么Azure APIM无法登录到Event Hub
我们有一个基于Azure的解决方案,可以在SharePoint网站上跟踪用户操作。 SharePoint扩展程序会产生JSON有效载荷,该有效负载已发送到 API Management …
如何在Python函数中使用Azure函数命令输出绑定?
我正在尝试设置Azure函数,以从EventHub“ A”接收消息,然后根据使用功能绑定的输入消息将消息发送到EventHub“ B”或C的一个。 Azure函数支持EventH…
更好的练习将消息发送到使用无服务器C#funcion的Azure事件中心
这是我的代码... namespaceMyNamespace { public class Ping { private readonly ILogger _logger; public Ping2(ILogger log) { _logger = log; } [F…
Azure应用功能应用程序' AppName'已关闭
我正在创建一个Azure应用功能,以从事件中心读取并写入另一个事件中心。最初,我只是从活动中心阅读并记录一些消息,这很好。 原始代码 [FunctionName…
事件中心的AVRO字节不能用Pyspark进行重新序列化
我们将使用( azure.schemaregistry.encoder.avroencoder ))发送AVRO数据)使用独立的python作业,我们可以使用另一个独立的解码器使用同一解码器进…