我正在使用 Flask 运行服务,当在主题上发布消息时,需要触发一些代码。我不确定如何创建订阅名称以及所有这些,但我想我可以破解它。我真正不知道的是如何不断地收听这个主题并启动过滤器,以便每当满足符合条件的消息时,它总是被触发。有什么地方可以引导我吗?
问问题
278 次
1 回答
1
您最好使用 Azure Functions,只要有新消息到达主题,就会触发它:
import azure.functions as func
import logging
import json
def main(msg: func.ServiceBusMessage):
logging.info('Python ServiceBus queue trigger processed message.')
result = json.dumps({
'message_id': msg.message_id,
'body': msg.get_body().decode('utf-8'),
'content_type': msg.content_type,
'expiration_time': msg.expiration_time,
'label': msg.label,
'partition_key': msg.partition_key,
'reply_to': msg.reply_to,
'reply_to_session_id': msg.reply_to_session_id,
'scheduled_enqueue_time': msg.scheduled_enqueue_time,
'session_id': msg.session_id,
'time_to_live': msg.time_to_live,
'to': msg.to,
'user_properties': msg.user_properties,
'metadata' : msg.metadata
})
logging.info(result)
于 2021-01-15T21:20:46.400 回答