azure-eventhub-capture相关内容

具有事件中心触发器的Azure函数写入重复消息

我有一个具有事件中心触发器的Azure函数。此集线器从设备接收消息并将其存储在Blob中。最近,我注意到重复的消息存储在BLOB中。BLOB商店中的文件是按上次修改日期排序的,如果你看一下屏幕截图,你会发现情况并非如此。以前是否有人见过此问题? 我还有一个写入cosmos DB的Azure函数,对于blob中的重复消息,cosmos中没有对应的重复消息。 我还连接了也没有任何重复消息的 ..

PySpark:反序列化eventhub捕获avro文件中包含的Avro序列化消息

初始情况 AVRO序列化事件被发送到天蓝色事件中心.这些事件使用azure事件中心捕获功能持久存储.捕获的数据以及事件中心元数据均以Apache Avro格式编写.捕获的avro文件中包含的原始事件应使用(py)Spark进行分析. 问题 如何使用(py)Spark反序列化包含在AVRO文件的字段/列中的AVRO序列化事件?(注释:该事件的平均模式无法被阅读器应用程序识别,但是它 ..
发布时间:2021-04-08 19:35:21 其他开发