在我的python Azure函数中(使用ServiceBustigger)是否有机会读取一堆消息
这个问题其实很简单。我做了很多尝试,但Azure功能框架在读取来自Azure服务总线的消息后,似乎每次调用一条消息,而不管预取值有多大或设置了任何参数
我想处理整个消息获取过程,因为当您必须处理数百万条消息时,一次处理一条或多条消息会产生不同
这是我的配置:
function.json
{
"scriptFile": "main.py",
"entryPoint": "function_handler",
"bindings": [{
"name": "msg",
"type": "serviceBusTrigger",
"direction": "in",
"topicName": "topic-name",
"subscriptionName": "topic-subscription-name"
}]
}
main.py
import azure.functions as func
import json
def function_handler(msg: func.ServiceBusMessage):
print(str(msg))
host.json
{
"version": "2.0",
"extensionBundle": {
"id": "Microsoft.Azure.Functions.ExtensionBundle",
"version": "[1.*, 2.0.0)"
},
"extensions": {
"serviceBus": {
"prefetchCount": 100,
"messageHandlerOptions": {
"autoComplete": true,
"maxConcurrentCalls": 6,
"maxAutoRenewDuration": "00:05:00"
}
}
}
}
我认为您可能需要一个异步服务总线触发器:
__init__.py
host.json
我可以得到:
相关问题 更多 >
编程相关推荐