alexandrubau/messenger-azure-queue-transport

Symfony's Messenger 组件的 Azure 存储队列传输。

v1.7.0 2024-08-19 13:17 UTC

This package is auto-updated.

Last update: 2024-09-19 13:31:02 UTC


README

Symfony's Messenger 组件的 Azure 队列传输。

Travis (.org) Packagist Version Software License

安装

messenger-azure-queue-transport 组件需要 PHP 7.3+ 和 Symfony 4.3+。

您可以使用 Symfony Flex 安装此组件。

composer require alexandrubau/messenger-azure-queue-transport

基本用法

设置环境变量

MESSENGER_TRANSPORT_DSN=azurequeue://<account_name>:<account_key>@default

如果您的 Account Name 或 Account Key 包含特殊字符,您可以使用 PHP 的 rawurlencode() 函数来编码它们。

设置 messenger 传输配置

framework:
    messenger:
        transports:
            azure_queues:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: <your_queue_name>
                    visibility_timeout: <visibility_timeout_in_seconds>
                    time_to_live: <time_to_live_in_seconds>
                    results_limit: <how_many_messages_to_read>

可以通过 DSN 或通过 messenger.yaml 中传输下的 options 键来配置选项。示例

MESSENGER_TRANSPORT_DSN=azurequeue://<account_name>:<account_key>@default?queue_name=<your_queue_name>&visibility_timeout=<visibility_timeout_in_seconds>&time_to_live=<time_to_live_in_seconds>&results_limit=<how_many_messages_to_read>

别忘了在 Azure 队列存储中创建提供的名称的队列。

进一步阅读

  1. Messenger 组件
  2. Messenger:同步与排队消息处理
  3. Azure 存储队列
  4. Azure 存储队列 REST API