進口asyncio
進口操作係統
從azure.eventhub。aio進口EventHubConsumerClient
CONNECTION_STR = " Connection_string "
EVENTHUB_NAME = " event_hub "
異步def on_event (partition_context、事件):
#把代碼放在這裏。
#如果i / o密集型操作,異步將有更好的性能。
打印(“收到分區事件:{}”。.format (partition_context.partition_id))
打印(事件)
異步def on_partition_initialize (partition_context):
#把代碼放在這裏。
打印(“分區:{}被初始化。“.format (partition_context.partition_id))
異步def on_partition_close (partition_context原因):
#把代碼放在這裏。
打印(“分區:{}已經關閉,關閉的原因:{}”。.format (
partition_context.partition_id,
原因
))
異步def on_error (partition_context、錯誤):
#把代碼放在這裏。partition_context可以沒有on_error回調。
如果partition_context:
打印(“一個例外:{}發生在接收從分區:{}”。.format (
partition_context.partition_id,
錯誤
))
其他:
打印(“一個例外:{}在負載平衡過程中發生。”.format(錯誤)
異步def main ():
客戶= EventHubConsumerClient.from_connection_string (
conn_str = CONNECTION_STR,
consumer_group = " $違約",
eventhub_name = eventhub_name
)
異步客戶端:
等待client.receive (
on_event = on_event,
on_error = on_error,
on_partition_close = on_partition_close,
on_partition_initialize = on_partition_initialize,
starting_position =“1”,“1”號從一開始的分區。@latest
)
等待main ()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
我能接收數據的json,但是拚花的供應商發送數據。的數據修改才能得到什麼拚花嗎?
