具有事件中心触发器的Azure函数写入重复消息 我有一个具有事件中心触发器的Azure函数。此集线器从设备接收消息并将其存储在Blob中。最近,我注意到重复的消息存储在BLOB中。BLOB商店中的文件是按上次修改日期排序的,如果你看一下屏幕截图,你会发现情况并非如此。以前是否有人见过此问题? 我还有一个写入cosmos DB的Azure函数,对于blob中的重复消息,cosmos中没有对应的重复消息。 我还连接了也没有任何重复消息的 .. 发布时间:2022-02-24 12:29:17 azure-functions azure-eventhub azure-blob-storage azure-eventhub-capture 其他开发
PySpark:反序列化eventhub捕获avro文件中包含的Avro序列化消息 初始情况 AVRO序列化事件被发送到天蓝色事件中心.这些事件使用azure事件中心捕获功能持久存储.捕获的数据以及事件中心元数据均以Apache Avro格式编写.捕获的avro文件中包含的原始事件应使用(py)Spark进行分析. 问题 如何使用(py)Spark反序列化包含在AVRO文件的字段/列中的AVRO序列化事件?(注释:该事件的平均模式无法被阅读器应用程序识别,但是它 .. 发布时间:2021-04-08 19:35:21 apache-spark pyspark avro azure-eventhub-capture 其他开发