2.16. bucket 通知

流程

1. 创建带有请求格式的主题：

   语法

   POST
   Action=CreateTopic
   &Name=TOPIC_NAME
   [&Attributes.entry.1.key=amqp-exchange&Attributes.entry.1.value=EXCHANGE]
   [&Attributes.entry.2.key=amqp-ack-level&Attributes.entry.2.value=none|broker|routable]
   [&Attributes.entry.3.key=verify-ssl&Attributes.entry.3.value=true|false]
   [&Attributes.entry.4.key=kafka-ack-level&Attributes.entry.4.value=none|broker]
   [&Attributes.entry.5.key=use-ssl&Attributes.entry.5.value=true|false]
   [&Attributes.entry.6.key=ca-location&Attributes.entry.6.value=FILE_PATH]
   [&Attributes.entry.7.key=OpaqueData&Attributes.entry.7.value=OPAQUE_DATA]
   [&Attributes.entry.8.key=push-endpoint&Attributes.entry.8.value=ENDPOINT]
   [&Attributes.entry.9.key=persistent&Attributes.entry.9.value=true|false]

   以下是请求参数：

   • 端点 ：将通知发送到的端点的 URL。
   • OpaqueData: 不透明数据在主题配置中设置，并添加到该主题触发的所有通知。
   • persistent ：指示对此端点的通知是否是持久的，是否为异步的。默认值为 false。

   • HTTP 端点：

     • URL: https://FQDN:PORT
     • port defaults to: 分别为 HTTP[S] 使用 80/443。
     • verify-ssl ：指示服务器证书是否由客户端验证。默认情况下，它是 true。

   • AMQP0.9.1 端点：

     • URL: amqp://USER:PASSWORD@FQDN:PORT[/VHOST].
     • 用户和密码分别默认为： guest 和 guest。
     • 应当通过 HTTPS 提供用户和密码详细信息，否则主题创建请求将被拒绝。
     • 端口默认为 5672。
     • vhost 默认为："/"
     • amqp-exchange ：该交换必须存在，并且能够根据主题路由消息。这是用于 AMQP0.9.1 的强制参数。指向同一端点的不同主题必须使用相同的交换。

     • AMQP-ack-level ：不需要结束确认，因为消息在代理中可以保留，然后再将它们传送到最终目的地。有三个确认方法：

       • none ：当发送到代理，则消息被视为已发送。
       • broker: 默认情况下，代理确认信息将被视为 已发送。

       • routable ：如果代理可路由到使用者，则消息被视为已发送。

         注意

         特定参数的键和值不必驻留在同一行中或任何特定顺序，但必须使用相同的索引。属性索引不需要是连续的，或从任何特定值开始。

         注意

         topic-name 用于 AMQP 主题。

   • Kafka 端点：

     • URL: kafka://USER:PASSWORD@FQDN:PORT.
     • use-ssl 默认被设置为 false。如果将 use-ssl 设置为 true，则与代理的连接会使用安全的连接。
     • 如果提供了 ca-location，并且使用安全连接，则会使用指定的 CA 而不是默认的端口来验证代理。
     • 用户和密码只能通过 HTTP[S] 提供。否则，主题创建请求将被拒绝。
     • 用户和密码只能与 use-ssl 一起提供，否则与代理的连接将失败。
     • 端口默认为: 9092。

     • Kafka-ack-level ：无需结束确认，因为信息在传送到最终目的地前可能会保留在代理中。存在两个确认方法：

       • none ：当发送到代理，则消息被视为已发送。
       • broker: 默认情况下，代理确认信息将被视为 已发送。

流程

1. 使用以下请求格式获取主题信息：

   语法

   POST
   Action=GetTopic
   &TopicArn=TOPIC_ARN

   以下是响应格式的示例：

   <GetTopicResponse>
   <GetTopicRersult>
   <Topic>
   <User></User>
   <Name></Name>
   <EndPoint>
   <EndpointAddress></EndpointAddress>
   <EndpointArgs></EndpointArgs>
   <EndpointTopic></EndpointTopic>
   <HasStoredSecret></HasStoredSecret>
   <Persistent></Persistent>
   </EndPoint>
   <TopicArn></TopicArn>
   <OpaqueData></OpaqueData>
   </Topic>
   </GetTopicResult>
   <ResponseMetadata>
   <RequestId></RequestId>
   </ResponseMetadata>
   </GetTopicResponse>

   以下是标签和定义：

   • User ：创建该主题的用户的名称。
   • Name ：主题的名称.

   • JSON 格式的端点包括：

     • EndpointAddress ：端点 URL。如果端点 URL 包含用户和密码信息，则必须通过 HTTPS 进行请求。否则，主题获取请求将被拒绝。

       • EndPointArgs ：端点参数。
       • EndpointTopic ：发送到端点的主题名称可以与上例主题名称不同。
       • HasStoredSecret：当端点 URL 包含用户和密码信息时为 true。
       • Persistent: 当主题是持久的则为 true。
   • TopicArn: Topic ARN。
   • OpaqueData ：这是在主题上设置的不透明数据。

流程

1. 使用以下请求格式列出主题信息：

   语法

   POST
   Action=ListTopics

   以下是响应格式的示例：

   <ListTopicdResponse xmlns="https://sns.amazonaws.com/doc/2020-03-31/">
   <ListTopicsRersult>
   <Topics>
   <member>
   <User></User>
   <Name></Name>
   <EndPoint>
   <EndpointAddress></EndpointAddress>
   <EndpointArgs></EndpointArgs>
   <EndpointTopic></EndpointTopic>
   </EndPoint>
   <TopicArn></TopicArn>
   <OpaqueData></OpaqueData>
   </member>
   </Topics>
   </ListTopicsResult>
   <ResponseMetadata>
   <RequestId></RequestId>
   </ResponseMetadata>
   </ListTopicsResponse>

   注意

   如果端点 URL 包含用户和密码信息，在任何主题中，则必须通过 HTTPS 进行请求。否则，主题列表请求将被拒绝。

流程

1. 使用以下请求格式删除主题：

   语法

   POST
   Action=DeleteTopic
   &TopicArn=TOPIC_ARN

   以下是响应格式的示例：

   <DeleteTopicResponse xmlns="https://sns.amazonaws.com/doc/2020-03-31/">
   <ResponseMetadata>
   <RequestId></RequestId>
   </ResponseMetadata>
   </DeleteTopicResponse>