发布事件到 AMQP (RabbitMQ)
MinIO 支持发布存储桶通知事件到AMQP 0-9-1服务端点，例如RabbitMQ.
MinIO 依赖于https://github.com/streadway/amqpproject for AMQP connectivity. The project is primarily tested againstRabbitMQdeployments，不过其他AMQP 0-9-1 兼容服务可能同样适用。本页中的过程假设使用 AMQP 0-9-1 协议作为服务端点的 RabbitMQ 部署。
为 MinIO 部署添加 AMQP 端点
以下过程添加一个新的 AMQP 服务端点以支持存储桶通知在 MinIO 部署中。
前提条件
AMQP 0-9-1 服务端点
MinIO 依赖于https://github.com/streadway/amqpproject for AMQP connectivity. The project is primarily tested againstRabbitMQdeployments，不过其他AMQP 0-9-1 兼容服务可能同样适用。此过程假设使用 0-9-1 协议作为服务端点的 RabbitMQ 部署。
如果 AMQP 服务需要身份验证，您必须在配置过程中提供适当的用户名和密码，以授予 MinIO 访问该服务的权限。
MinIOmc命令行工具
1) 将 AMQP 端点添加到 MinIO
您可以使用环境变量配置新的 AMQP 服务端点or通过设置运行时配置设置。
MinIO支持通过指定AMQP服务端点及相关配置设置来使用环境变量. Theminio server进程将在下次启动时应用指定的设置。
以下示例代码设置全部environment variables
与配置 AMQP 服务端点相关。最低必需变量是MINIO_NOTIFY_AMQP_ENABLE和MINIO_NOTIFY_AMQP_URL:
export MINIO_NOTIFY_AMQP_ENABLE_<IDENTIFIER>="on"
export MINIO_NOTIFY_AMQP_URL_<IDENTIFIER>="<ENDPOINT>"
export MINIO_NOTIFY_AMQP_EXCHANGE_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_EXCHANGE_TYPE_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_ROUTING_KEY_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_MANDATORY_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_DURABLE_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_NO_WAIT_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_INTERNAL_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_AUTO_DELETED_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_DELIVERY_MODE_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_QUEUE_DIR_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_QUEUE_LIMIT_<IDENTIFIER>="<string>"
export MINIO_NOTIFY_AMQP_COMMENT_<IDENTIFIER>="<string>"
替换
<IDENTIFIER>使用唯一的描述性字符串作为 AMQP 服务端点。使用相同的<IDENTIFIER>所有与新 AMQP 服务端点相关的环境变量的值。 以下示例假设标识符为PRIMARY.如果指定的
<IDENTIFIER>匹配 MinIO 部署上的现有 AMQP 服务端点，新的设置覆盖该端点的任何现有设置。使用mc admin config get notify_amqp审查 MinIO 部署中当前配置的 AMQP 端点。替换
<ENDPOINT>使用 AMQP 服务端点的 URL。 例如：amqp://user:password@hostname:port
看AMQP 服务用于存储桶通知有关每个环境变量的完整文档。
MinIO 支持在运行状态下添加或更新 AMQP 端点minio server使用该过程mc admin config set命令
和notify_amqp配置键。您必须重启minio server应用任何新的或更新的配置设置的过程。
以下示例代码设置全部与配置 AMQP 服务端点相关的设置。最低必需设置是notify_amqp url:
mc admin config set ALIAS/ notify_amqp:IDENTIFIER \
url="ENDPOINT" \
exchange="<string>" \
exchange_type="<string>" \
routing_key="<string>" \
mandatory="<string>" \
durable="<string>" \
no_wait="<string>" \
internal="<string>" \
auto_deleted="<string>" \
delivery_mode="<string>" \
queue_dir="<string>" \
queue_limit="<string>" \
comment="<string>"
替换
IDENTIFIER使用唯一的描述性字符串作为 AMQP 服务端点。本过程中的以下示例 假设标识符为PRIMARY.如果指定的
IDENTIFIER匹配 MinIO 部署上的现有 AMQP 服务端点，新的设置覆盖该端点的任何现有设置。使用mc admin config get notify_amqp审查 MinIO 部署中当前配置的 AMQP 端点。替换
ENDPOINT使用 AMQP 服务端点的 URL。 例如：amqp://user:password@hostname:port
看AMQP 桶通知配置设置有关每个设置的完整文档。
1) 重启 MinIO 部署
您必须重启 MinIO 部署才能使配置更改生效。
使用mc admin service restart重启部署的命令。
mc admin service restart ALIAS
替换ALIAS随着别名部署的重新启动。
Theminio server进程在启动时会为每个配置的 AMQP 目标打印一行信息，示例如下：
SQS ARNs: arn:minio:sqs::primary:amqp
在配置存储桶通知并将关联的 AMQP 部署设为目标时，必须指定 ARN 资源。
识别您的存储桶通知的 ARN
你定义了<IDENTIFIER>在先前创建端点时分配给您的存储桶通知的目标 ARN。
以下步骤返回在部署上配置的 ARN。
通过查找先前创建的 ARN来识别它。<IDENTIFIER>您指定的。
审查 JSON 输出
复制并运行以下命令，将
ALIAS随着别名部署的。mc admin info --json ALIAS
在 JSON 输出中，查找键
info.sqsARN.您需要的ARN是与该键匹配的值
<IDENTIFIER>您指定的。例如，
arn:minio:sqs::primary:amqp.
使用 jq 解析 JSON 获取值
3) 使用 AMQP 端点作为目标配置存储桶通知
使用mc event add添加新存储桶通知事件的命令，将已配置的 AMQP 服务设为目标：
mc event add ALIAS/BUCKET arn:minio:sqs::primary:amqp \
--event EVENTS
使用mc event ls要查看为给定通知目标配置的所有存储桶事件：
mc event ls ALIAS/BUCKET arn:minio:sqs::primary:amqp
4) 验证已配置的事件
对配置了新事件的存储桶执行操作，并
检查 AMQP 服务以获取通知数据。所需操作
取决于您配置的events在配置存储桶通知时已指定。
例如，如果存储桶通知配置包含s3:ObjectCreated:Put事件，您可以使用mc cp在存储桶中创建新对象并触发通知的命令。
mc cp ~/data/new-object.txt ALIAS/BUCKET
更新 MinIO 部署中的 AMQP 端点
以下过程更新现有的 AMQP 服务端点以提供支持存储桶通知在 MinIO 部署中。
前提条件
AMQP 0-9-1 服务端点
MinIO 依赖于https://github.com/streadway/amqpproject for AMQP connectivity. The project is primarily tested againstRabbitMQdeployments，不过其他AMQP 0-9-1 兼容服务可能也可以工作。此过程假定一个 RabbitMQ 部署 作为服务端点。
如果 AMQP 服务需要身份验证，您必须在配置过程中提供适当的用户名和密码，以授予 MinIO 访问该服务的权限。
MinIOmc命令行工具
1) 列出部署中已配置的 AMQP 端点
使用mc admin config get列出部署中当前配置的 AMQP 服务端点的命令：
mc admin config get ALIAS/ notify_amqp
替换ALIAS随着别名MinIO 部署的。
命令输出类似于以下内容：
notify_amqp:primary delivery_mode="0" exchange_type="" no_wait="off" queue_dir="" queue_limit="0" url="amqp://user:password@hostname:port" auto_deleted="off" durable="off" exchange="" internal="off" mandatory="off" routing_key=""
notify_amqp:secondary delivery_mode="0" exchange_type="" no_wait="off" queue_dir="" queue_limit="0" url="amqp://user:password@hostname:port" auto_deleted="off" durable="off" exchange="" internal="off" mandatory="off" routing_key=""
Thenotify_amqpkey 是用于配置AMQP 通知设置. Theurlkey 指定给定 AMQP 服务端点的notify_amqpkey. Thenotify_amqp:<IDENTIFIER>suffix
描述了该 AMQP 服务端点的唯一标识符。
记下您要为下一步更新的 AMQP 服务端点的标识符。
2) 更新 AMQP 端点
使用mc admin config set设置 AMQP 服务端点新配置的命令：
mc admin config set ALIAS/ notify_amqp:<IDENTIFIER> \
url="amqp://user:password@hostname:port" \
exchange="<string>" \
exchange_type="<string>" \
routing_key="<string>" \
mandatory="<string>" \
durable="<string>" \
no_wait="<string>" \
internal="<string>" \
auto_deleted="<string>" \
delivery_mode="<string>" \
queue_dir="<string>" \
queue_limit="<string>" \
comment="<string>"
Thenotify_amqp url配置设置是最小值AMQP 服务端点所必需的。所有其他配置设置都是可选的. 查看AMQP 通知设置有关 AMQP 配置设置的完整列表。
3) 重启 MinIO 部署
您必须重启 MinIO 部署以使配置更改生效。
使用mc admin service restart重启部署的命令。
mc admin service restart ALIAS
替换ALIAS随着别名部署的重新启动。
Theminio server进程在启动时会为每个配置的 AMQP 目标打印一行信息，示例如下：
SQS ARNs: arn:minio:sqs::primary:amqp
4) 验证更改
对配置了事件通知的存储桶执行操作，使用更新后的AMQP服务端点，并检查AMQP服务中的通知数据。所需操作取决于events在配置存储桶通知时已指定。
例如，如果存储桶通知配置包含s3:ObjectCreated:Put事件，您可以使用mc cp在存储桶中创建新对象并触发通知的命令。
mc cp ~/data/new-object.txt ALIAS/BUCKET
