快速入门

场景描述

您可以根据业务需要创建普通队列，用于存储消息。

API调用方法请参考如何调用API。

前提条件

• 已获取IAM的Endpoint，具体请参见地区和终端节点。
• 已获取DMS的Endpoint，具体请参见地区和终端节点。

创建队列

{
  "name" : "queue-001",
  "queue_mode" : "FIFO",
  "redrive_policy" : "enable",
  "max_consume_count" : 3
}

• name：表示队列的名称，必须唯一，由您自行定义。
• queue_mode：表示队列类型。取值范围：
  • NORMAL：普通队列，更高的并发性能，不保证先入先出（FIFO）的严格顺序。
  • FIFO：有序队列，保证消息先入先出（FIFO）的严格顺序。
  • KAFKA_HA：高可靠模式的kafka队列。消息多副本同步落盘，保证消息的可靠性。
  • KAFKA_HT：高吞吐模式的kafka队列。消息副本异步落盘，具有较高的性能。
• redrive_policy：表示是否开启死信消息。取值范围：
  • enable：开启
  • disable：不开启
• max_consume_count：表示最大确认消费失败的次数，当达到最大确认失败次数后，DMS会将该条消息转存到死信队列中。

参数更多描述，请参考创建队列。