是否无论如何要删除/清除 Azure 门户中 Azure 服务总线队列中的活动/死信消息？目前我们已经向我们的队列发送了几条消息，而活动消息和一些死信消息都在那里无所事事，而且我们的服务总线订阅者没有以某种方式触发，所以我们想删除这些消息以使我们的队列又干净了。为了等到服务总线在过期后丢弃这些消息，我们可以自己手动删除它们吗？
【问题讨论】：
标签： azure azureservicebus azure-servicebus-queues
是否有办法从 Azure 门户中的 Azure 服务总线队列中删除/清除活动/死信消息？
目前不支持清除操作。有一个feature request可以实现purge，但是还没有实现。
您可以使用一些工具来执行类似清除的操作。 ServiceBus Explorer 可以清除常规和死信队列上的消息（接收和删除选项）。
或者，您也可以编写一个脚本来执行此操作。
【讨论】：
使用服务总线资源管理器，您可以连接到 Azure 服务总线并管理消息传递实体。您可以下载工具here。
下载工具后，您将运行“ServiceBusExplorer.exe” 在 Service Bus Explorer 中，转到 File Connect
输入您可以在中找到的连接字符串 仪表板 --> 服务总线 --> --> 共享访问策略
连接成功后你将能够看到连接的服务总线中的所有主题队列选择你想要访问的队列
您可以随意接收和删除
【讨论】：
您可以为此调用服务总线 API。使用 DELETE 方法将从队列中检索和删除消息。官方文档是here。 API 是
https://{SERVICENAMESPACE}.servicebus.windows.net/{QUEUE_NAME}/$DeadLetterQueue/messages/head
。和
https://{SERVICENAMESPACE}.servicebus.windows.net/{QUEUE_NAME}/messages/head
您可以使用如下 curl 来接收和删除消息，编写一个 while 循环可以实现您的目标。 SAS token 可以按照官方文档获取。
curl -X DELETE -H "Authorization: SharedAccessSignature sr=<NAMESPACE NAME>.servicebus.windows.net&sig=<SHARED ACCESS KEY>&se=<TOKEN EXPIRY INSTANT>&skn=<SHARED KEY NAME>" ${URL}
获取 SAS 令牌代码：
get_sas_token() {
eval ${CONNECT_STRING}
local EXPIRY=${EXPIRY:=$((60 * 60 * 1))} # Default token expiry is 1 hour
local ENCODED_URI=$(echo -n ${Endpoint} | jq -s -R -r @uri)
local TTL=$(($(date +%s) + ${EXPIRY}))
local UTF8_SIGNATURE=$(printf "%s\n%s" ${ENCODED_URI} ${TTL} | iconv -t utf8)
local HASH=$(echo -n "${UTF8_SIGNATURE}" | openssl sha256 -hmac ${SharedAccessKey} -binary | base64)
local ENCODED_HASH=$(echo -n ${HASH} | jq -s -R -r @uri)
AUTH_HEADER="SharedAccessSignature sr=${ENCODED_URI}&sig=${ENCODED_HASH}&se=${TTL}&skn=${SharedAccessKeyName}"
}
删除死信队列（您可以更改 URL 以删除活动消息）：
purge_dlq_queue() {
local DLQ_QUEUE_URL="https://${SERVICENAMESPACE}.servicebus.windows.net/${QUEUE_NAME}/\$DeadLetterQueue/messages/head"
local count=1000
echo "cleaning the dead letters messages from the message queue..."
while [[ ${count} -ge 0 ]]
do
local STATUS_CODE=$(curl -I -X DELETE -H "Authorization: ${AUTH_HEADER}" ${DLQ_QUEUE_URL} 2>/dev/null | head -n 1 | cut -d$' ' -f2)
if [[ STATUS_CODE -ge 300 ]]; then
echo "Exit dead letters message queue cleaning with code ${STATUS_CODE}"
return 1
elif [[ STATUS_CODE -eq 204 ]]; then
echo "dead letters message queue has been cleaned"
return 0
fi
let count--
done
echo "Exit with maxium number tries."
return 1
}
脚本代码可以从here查看
【讨论】：