blocks|key|759863|text|对于任何来到这里的人来说，正在寻找一种在C#中集体删除SQS消息的方法...|type|unstyled|depth|inlineStyleRanges|entityRanges|data|759864|//C#+Console+app+which+deletes+all+messages+from+a+specified+queue
//AWS+.NET+library+required.

using+System;
using+System.Net;
using+System.Configuration;
using+System.Collections.Specialized;
using+System.IO;
using+System.Linq;
using+System.Text;

using+Amazon;
using+Amazon.SQS;
using+Amazon.SQS.Model;
using+System.Timers;

using+System.Collections.Generic;
using+System.Text.RegularExpressions;
using+System.Diagnostics;

namespace+QueueDeleter
{
++++class+Program
++++{
++++++++public+static+System.Timers.Timer+myTimer;
++++++++static+NameValueCollection+appConfig+=+ConfigurationManager.AppSettings;
++++++++static+string+accessKeyID+=+appConfig["AWSAccessKey"];
++++++++static+string+secretAccessKeyID+=+appConfig["AWSSecretKey"];
++++++++static+private+AmazonSQS+sqs;

++++++++static+string+myQueueUrl+=+"https://queue.amazonaws.com/1640634564530223/myQueueUrl";
++++++++public+static+String+messageReceiptHandle;

++++++++public+static+void+Main(string[]+args)
++++++++{
++++++++++++sqs+=+AWSClientFactory.CreateAmazonSQSClient(accessKeyID,+secretAccessKeyID);

++++++++++++myTimer+=+new+System.Timers.Timer();
++++++++++++myTimer.Interval+=+10;
++++++++++++myTimer.Elapsed+%2B=+new+ElapsedEventHandler(checkQueue);
++++++++++++myTimer.AutoReset+=+true;
++++++++++++myTimer.Start();
++++++++++++Console.Read();
++++++++}

++++++++static+void+checkQueue(object+source,+ElapsedEventArgs+e)
++++++++{
++++++++++++myTimer.Stop();

++++++++++++ReceiveMessageRequest+receiveMessageRequest+=+new+ReceiveMessageRequest();
++++++++++++receiveMessageRequest.QueueUrl+=+myQueueUrl;
++++++++++++ReceiveMessageResponse+receiveMessageResponse+=+sqs.ReceiveMessage(receiveMessageRequest);
++++++++++++if+(receiveMessageResponse.IsSetReceiveMessageResult())
++++++++++++{
++++++++++++++++ReceiveMessageResult+receiveMessageResult+=+receiveMessageResponse.ReceiveMessageResult;

++++++++++++++++if+(receiveMessageResult.Message.Count+<+1)
++++++++++++++++{
++++++++++++++++++++Console.WriteLine("Can't+find+any+visible+messages.");
++++++++++++++++++++myTimer.Start();
++++++++++++++++++++return;
++++++++++++++++}

++++++++++++foreach+(Message+message+in+receiveMessageResult.Message)
++++++++++++{
++++++++++++++++Console.WriteLine("Printing+received+message.\n");

++++++++++++++++messageReceiptHandle+=+message.ReceiptHandle;

++++++++++++++++Console.WriteLine("Message+Body:");
++++++++++++++++if+(message.IsSetBody())
++++++++++++++++{
++++++++++++++++++++Console.WriteLine("++++Body:+{0}",+message.Body);
++++++++++++++++}
++++++++++++++++sqs.DeleteMessage(new+DeleteMessageRequest().WithQueueUrl(myQueueUrl).WithReceiptHandle(messageReceiptHandle));
++++++++++++}
++++++++}
++++++++else
++++++++{
++++++++++++Console.WriteLine("No+new+messages.");
++++++++}

+++++++++myTimer.Start();
++++++++}
++++}
}|code-block|syntax|javascript|759865|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

For anyone who has come here, looking for a way to delete SQS messages en masse in C#... 

<pre><code>//C# Console app which deletes all messages from a specified queue
//AWS .NET library required.

using System;
using System.Net;
using System.Configuration;
using System.Collections.Specialized;
using System.IO;
using System.Linq;
using System.Text;

using Amazon;
using Amazon.SQS;
using Amazon.SQS.Model;
using System.Timers;

using System.Collections.Generic;
using System.Text.RegularExpressions;
using System.Diagnostics;

namespace QueueDeleter
{
 class Program
 {
 public static System.Timers.Timer myTimer;
 static NameValueCollection appConfig = ConfigurationManager.AppSettings;
 static string accessKeyID = appConfig["AWSAccessKey"];
 static string secretAccessKeyID = appConfig["AWSSecretKey"];
 static private AmazonSQS sqs;

 static string myQueueUrl = "https://queue.amazonaws.com/1640634564530223/myQueueUrl";
 public static String messageReceiptHandle;

 public static void Main(string[] args)
 {
 sqs = AWSClientFactory.CreateAmazonSQSClient(accessKeyID, secretAccessKeyID);

 myTimer = new System.Timers.Timer();
 myTimer.Interval = 10;
 myTimer.Elapsed += new ElapsedEventHandler(checkQueue);
 myTimer.AutoReset = true;
 myTimer.Start();
 Console.Read();
 }

 static void checkQueue(object source, ElapsedEventArgs e)
 {
 myTimer.Stop();

 ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
 receiveMessageRequest.QueueUrl = myQueueUrl;
 ReceiveMessageResponse receiveMessageResponse = sqs.ReceiveMessage(receiveMessageRequest);
 if (receiveMessageResponse.IsSetReceiveMessageResult())
 {
 ReceiveMessageResult receiveMessageResult = receiveMessageResponse.ReceiveMessageResult;

 if (receiveMessageResult.Message.Count &lt; 1)
 {
 Console.WriteLine("Can't find any visible messages.");
 myTimer.Start();
 return;
 }

 foreach (Message message in receiveMessageResult.Message)
 {
 Console.WriteLine("Printing received message.\n");

 messageReceiptHandle = message.ReceiptHandle;

 Console.WriteLine("Message Body:");
 if (message.IsSetBody())
 {
 Console.WriteLine(" Body: {0}", message.Body);
 }
 sqs.DeleteMessage(new DeleteMessageRequest().WithQueueUrl(myQueueUrl).WithReceiptHandle(messageReceiptHandle));
 }
 }
 else
 {
 Console.WriteLine("No new messages.");
 }

 myTimer.Start();
 }
 }
}
</code></pre>

blocks|key|759911|text|我认为最好的方法是删除队列并重新创建它，只有2个请求。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|759912|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

I think the best way would be to delete the queue and create it again, just 2 requests.

blocks|key|759936|text|检查队列中的第一个项目。向下滚动到队列中的最后一项。按住shift键，单击项目。将选择全部。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|759937|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

Check the first item in queue. Scroll down to last item in queue.
Hold shift, click on item. All will be selected.

blocks|key|543378|text|我认为最好的方法是将保留期改为1分钟，但如果有人需要，以下是Python代码：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|543379|#!/usr/bin/python
#+-*-+coding:+utf-8+-*-

import+boto.sqs
from+boto.sqs.message+import+Message
import+time
import+os

startTime+=+program_start_time+=+time.strftime("%25Y-%25m-%25d+%25H:%25M:%25S",+time.gmtime())

###+Lets+connect+to+SQS:
qcon+=+boto.sqs.connect_to_region(region,aws_access_key_id='xxx',aws_secret_access_key='xxx')
SHQueue+=+qcon.get_queue('SQS')
m+=+Message()
###+Read+file+and+write+to+SQS
counter+=+0
while+counter+<+1000:+++##+For+deleting+1000*10+items,+change+to+True+if+you+want+delete+all
++++links+=+SHQueue.get_messages(10)
++++for+link+in+links:
++++++++++++m+=+link
++++++++++++SHQueue.delete_message(m)
++++counter+%2B=+1
####+The+End
print+"\n\nTerminating...\n"
print+"Start:+",+program_start_time
print+"End+time:+",+time.strftime("%25Y-%25m-%25d+%25H:%25M:%25S",+time.gmtime())|code-block|syntax|javascript|543380|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I think best way is changing Retention period to 1 minute, but here is Python code if someone needs:

<pre><code>#!/usr/bin/python
# -*- coding: utf-8 -*-

import boto.sqs
from boto.sqs.message import Message
import time
import os

startTime = program_start_time = time.strftime("%Y-%m-%d %H:%M:%S", time.gmtime())

### Lets connect to SQS:
qcon = boto.sqs.connect_to_region(region,aws_access_key_id='xxx',aws_secret_access_key='xxx')
SHQueue = qcon.get_queue('SQS')
m = Message()
### Read file and write to SQS
counter = 0
while counter &lt; 1000: ## For deleting 1000*10 items, change to True if you want delete all
 links = SHQueue.get_messages(10)
 for link in links:
 m = link
 SHQueue.delete_message(m)
 counter += 1
#### The End
print "\n\nTerminating...\n"
print "Start: ", program_start_time
print "End time: ", time.strftime("%Y-%m-%d %H:%M:%S", time.gmtime())
</code></pre>

blocks|key|759992|text|从2014年12月起，sqs控制台在队列操作菜单中提供了一个清除队列选项。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|759993|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

As of December 2014, the sqs console now has a purge queue option in the queue actions menu.

blocks|key|543432|text|要从API中清除SQS，请参阅：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|543433|https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_PurgeQueue.html|offset|length|543434|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|2H|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|N|8|@]|9|@$D|O|E|P|1|Q]]|A|$]]|$1|F|3|-4|5|6|7|R|8|@]|9|@]|A|$]]]|G|$H|$5|I|J|K|A|$L|C]]]]

To purge an SQS from the API see:

<a href="https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_PurgeQueue.html" rel="nofollow noreferrer">https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_PurgeQueue.html</a>

During development, I'm generating a lot of bogus messages on my Amazon SQS. I was about to write a tiny app to delete all the messages (something I do frequently during development). Does anyone know of a tool to purge the queue?

Best way to delete messages from SQS during development

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

在开发过程中，我在我的Amazon SQS上生成了许多虚假消息。我正要写一个删除所有消息的小应用程序(这是我在开发过程中经常做的事情)。有没有人知道清除队列的工具？

问在开发期间从SQS中删除消息的最佳方法
EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在开发期间从SQS中删除消息的最佳方法EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在开发期间从SQS中删除消息的最佳方法
EN