如何轮询azure服务总线队列中的消息?

问题描述：

我如何轮询azure服务总线以连续检查消息?这是我从队列中接收消息的方式.

How do I poll the azure service bus to continuously check for the messages? Here is how I receive the message from the queue.

   from azure.servicebus import QueueClient

   client = QueueClient.from_connection_string(
       q_string,
       q_name)

   msg = None

   with client.get_receiver() as queue_receiver:
     messages = queue_receiver.fetch_next(max_batch_size=1, timeout=3)
     if len(messages) > 0:
        msg = messages[0]
        print(f"Received {msg.message}")

  return msg

我要不断寻找消息，然后对其进行处理.

I want to continuously look for the message and then process it.

答

正如George chen所说，我认为服务总线队列触发器符合您的要求.

As George chen says, I think service bus queue trigger meets your requirement.

_init_.py:

import logging

import azure.functions as func


def main(msg: func.ServiceBusMessage):
    logging.info('Python ServiceBus queue trigger processed message: %s',
                 msg.get_body().decode('utf-8'))

function.json:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "msg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "queueName": "test",
      "connection": "str"
    }
  ]
}

env var:

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=0730bowmanwindow;AccountKey=lti/ThmF+mw9BebOacp9gVazIh76Q39ecikHSCkaTcGK5hmInspX+EkjzpNmvCPWsnvapWziHQHL+kKt2V+lZw==;EndpointSuffix=core.windows.net",
    "FUNCTIONS_WORKER_RUNTIME": "python",
    "str": "Endpoint=sb://bowmantest.servicebus.xxxxxxx"
  }
}

如果是天蓝色，则环境变量是在配置设置上，而不是local.settings.json.

If on azure, the env var is on configuration settings instead of local.settings.json.

执行此操作时，触发器将帮助您捕获服务总线队列中的信息.(立即)

When you do this, the trigger will help you to capture the information in the service bus queue.(instant)

如何轮询azure服务总线队列中的消息?

相关推荐