Python中文
首页
教程
问答
标签
搜索
登录
注册
未保存事件中心检查点数据
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我正在从运行事件中心接收器实现:<a href="https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-python-get-started-send#create-a-python-script-to-receive-events" rel="nofollow noreferrer">https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-python-get-started-send#create-a-python-script-to-receive-events</a>,除了连接字符串等,我没有做任何更改</p> <p>创建数百个事件后,我可以看到接收方在存储帐户内创建了检查点文件夹,但当我再次运行接收方时,我看到它处理相同的事件</p> <p>每个分区创建的文件也是空的</p> <p>存储在consumerClient中提供:</p> <pre><code>checkpoint_store = BlobCheckpointStore.from_connection_string("...", "eventhubcontainer") client = EventHubConsumerClient.from_connection_string("...", consumer_group="$Default", eventhub_name="eventhub1", checkpoint_store=checkpoint_store) </code></pre> <p>读取事件后,还有一种保存检查点的方法:</p> <pre><code>await partition_context.update_checkpoint(event) </code></pre> <p>我是不是遗漏了什么</p> <hr/> <p>整个代码:</p> <pre><code>import asyncio from azure.eventhub.aio import EventHubConsumerClient from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore async def on_event(partition_context, event): print("Received the event: \"{}\" from the partition with ID: \"{}\"".format(event.body_as_str(encoding='UTF-8'), partition_context.partition_id)) await partition_context.update_checkpoint(event) async def main(): checkpoint_store = BlobCheckpointStore.from_connection_string("AZURE STORAGE CONNECTION STRING", "BLOB CONTAINER NAME") client = EventHubConsumerClient.from_connection_string("EVENT HUBS NAMESPACE CONNECTION STRING", consumer_group="$Default", eventhub_name="EVENT HUB NAME", checkpoint_store=checkpoint_store) async with client: await client.receive(on_event=on_event, starting_position="-1") if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(main()) </code></pre>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>更新SDK解决了这个问题。@AdamLing还为我澄清了评论中的元数据位置</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
如何将Python中的列表复制到给定的目标中?
1 回答
如何将python中的列表插入SQL表
3 回答
如何将python中的列表转换为numpy数组以放入十位
7 回答
如何将python中的列表输入javascript?
8 回答
如何将python中的列表返回给dag?
10 回答
如何将Python中的列表项重新排列成成对的元组/列表?
9 回答
如何将Python中的初始化对象序列化为XML?
9 回答
如何将python中的十进制字符串转换为数字?
3 回答
如何将Python中的原始输入文本转换为Tkinter中的标签?
3 回答
如何将python中的反斜杠命令转换为在Linux上运行
5 回答
如何将python中的命令行参数转换为字典?
1 回答
如何将python中的图像值传递到kivy中的kv文件?
5 回答
如何将Python中的图像数组(枕头对象)上传到Google云
2 回答
如何将Python中的图像编码为Base64?
9 回答
如何将python中的图像调整为灰度低分辨率,如MNIST时尚数据?
6 回答
如何将python中的多个html输出保存到单个文件(或多个)中?
5 回答
如何将Python中的多个ifelse语句重构为一个函数?
6 回答
如何将Python中的多处理与Django结合使用,从xml文件创建数千个模型实例?
6 回答
如何将python中的多级API响应转换为dataframe
2 回答
如何将python中的多线程编程模型转换为异步/等待模型?
4 回答