文档首页/ 分布式消息服务RocketMQ版/ API参考（阿布扎比区域）/ API V2（推荐）/ 消息管理/ 导出死信消息
更新时间：2023-05-06 GMT+08:00
查看PDF
分享

导出死信消息

功能介绍

导出死信消息。

URI

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

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

项目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

String

重试次数。

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

String

队列ID。

queue_offset

String

在队列中的偏移量。
表5 property_list

参数

参数类型

描述

name

String

属性名称。

value

String

属性值。

请求示例

导出死信消息。

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

导出死信消息成功。

错误码

请参见错误码。

父主题： 消息管理