Во время разработки я генерирую много фальшивых сообщений на своем азартном SQS. Я собирался написать небольшое приложение, чтобы удалить все сообщения (что-то, что я часто делаю во время разработки). Кто-нибудь знает инструмент для очистки очереди?
Лучший способ удалить сообщения из SQS во время разработки
Ответ 1
Если вы не хотите писать script или удалять свою очередь. Вы можете изменить конфигурацию очереди:
- Щелкните правой кнопкой мыши по очереди >
configure queue
- Измените
Message Retention period
на 1 минуту (минимальное время, в которое оно может быть установлено). - Подождите, пока все сообщения не исчезнут.
Я обнаружил, что этот способ хорошо работает для удаления всех сообщений в очереди без удаления очереди.
Ответ 2
По состоянию на декабрь 2014 года консоль sqs теперь имеет опцию очереди очистки в меню действий в очереди.
Ответ 3
Для тех, кто пришел сюда, ищет способ удаления сообщений SQS в маске С#...
//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 < 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();
}
}
}
Ответ 4
Проверьте первый элемент в очереди. Прокрутите вниз до последнего элемента в очереди. Держите shift, щелкните по элементу. Все будут выбраны.
Ответ 5
Я думаю, что лучший способ - удалить очередь и создать ее снова, всего 2 запроса.
Ответ 6
Я думаю, что лучший способ - изменить период хранения до 1 минуты, но вот код Python, если кому-то нужно:
#!/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 < 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())
Ответ 7
Вариант 1: boto sqs имеет метод purge_queue для python:
purge_queue(queue)
Purge all messages in an SQS Queue.
Parameters: queue (A Queue object) – The SQS queue to be purged
Return type: bool
Returns: True if the command succeeded, False otherwise
Источник: http://boto.readthedocs.org/en/latest/ref/sqs.html
Код, который работает для меня:
conn = boto.sqs.connect_to_region('us-east-1',
aws_access_key_id=AWS_ACCESS_KEY_ID,
aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
)
q = conn.create_queue("blah")
#add some messages here
#invoke the purge_queue method of the conn, and pass in the
#queue to purge.
conn.purge_queue(self.queue)
Для меня он удалил очередь. Однако Amazon SQS позволяет запускать его только раз в 60 секунд. Поэтому мне пришлось использовать вторичное решение ниже:
Вариант 2: выполните очистку, потребляя все сообщения в цикле while и выкидывая их:
all_messages = []
rs = self.queue.get_messages(10)
while len(rs) > 0:
all_messages.extend(rs)
rs = self.queue.get_messages(10)
Ответ 8
Если у вас есть доступ к консоли AWS, вы можете очистить очередь с помощью веб-интерфейса.
Шаги:
- Перейдите к сервисам → SQS
- Отфильтровать очереди с помощью "QUEUE_NAME"
- Щелкните правой кнопкой мыши на вашем имени очереди → очередь очистки
Это приведет к тому, что очередь будет очищена, и это должно быть завершено через 5 или 10 секунд.
Ниже описано, как выполнить эту операцию:
Ответ 9
Чтобы очистить SQS от API, выполните следующие действия:
https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_PurgeQueue.html