更新时间:2024-04-08 GMT+08:00

导出死信消息

功能介绍

导出死信消息。

URI

POST /v2/{project_id}/instances/{instance_id}/messages/export

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID,获取方式请参见获取项目ID

instance_id

String

实例ID。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

topic

String

主题名称。

msg_id_list

Array of strings

消息ID列表。

uniq_key_list

Array of strings

唯一Key列表。

响应参数

状态码: 200

表3 响应Body参数

参数

参数类型

描述

[数组元素]

Array of Message objects

消息。

表4 Message

参数

参数类型

描述

msg_id

String

消息ID。

instance_id

String

实例ID。

topic

String

主题名称。

store_timestamp

Number

存储消息的时间。

born_timestamp

Number

产生消息的时间。

reconsume_times

Integer

重试次数。

body

String

消息体。

body_crc

Number

消息体校验和。

store_size

Number

存储大小。

property_list

Array of property_list objects

消息属性列表。

born_host

String

产生消息的主机IP。

store_host

String

存储消息的主机IP。

queue_id

Integer

队列ID。

queue_offset

Integer

在队列中的偏移量。

表5 property_list

参数

参数类型

描述

name

String

属性名称。

value

String

属性值。

请求示例

导出主题中指定消息ID和Key的死信消息。

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/export

{
  "topic" : "%DLQ%group1",
  "msg_id_list" : [ "C0A8011700002774000000000013B19D", "C0A8011700002774000000000013B30F" ],
  "uniq_key_list" : [ "7F000001001C18B4AAC26B8AED170010", "7F000001001C18B4AAC26B8AEE030015" ]
}

响应示例

状态码: 200

导出死信消息成功。

{
  "topic" : "topic_01",
  "body" : "Hello world",
  "property_list" : {
    "name" : "ORIGIN_MESSAGE_ID",
    "value" : "C0A8005B00002775000000000000EBAE"
  },
  "msg_id" : "C0A8005B0000277500000000000133A2",
  "instance_id" : "56055acb-3c3b-4481-aeab-10464086c2b4",
  "store_timestamp" : 1662690563020,
  "born_timestamp" : 1662690324415,
  "reconsume_times" : 5,
  "body_crc" : 198614610,
  "store_size" : 317,
  "born_host" : "10.58.233.224:63529",
  "store_host" : "192.168.0.91:10101",
  "queue_id" : 0,
  "queue_offset" : 0
}

状态码

状态码

描述

200

导出死信消息成功。

错误码

请参见错误码