Sellerie mit SQS-Backend nicht prüfen

Question

Ich verwende Sellerie, um asynchrone Aufgaben zu verarbeiten, und ich verwende SQS bei Amazon als Messaging-Server. Meine Aufgaben haben plötzlich gestoppt Verarbeitung, und als ich ging mit der Sellerie Warteschlange zu inspizieren:

from celery.task.control import inspect 
i = inspect() 
i.scheduled() 

ich den Fehler erhalten:

SQSError: SQSError: 400 Bad Request 
<?xml version="1.0"?><ErrorResponse xmlns="http://queue.amazonaws.com/doc/2012-11-05/"><Error><Type>Sender</Type><Code>InvalidParameterValue</Code><Message>Can only include alphanumeric characters, hyphens, or underscores. 1 to 80 in length</Message><Detail/></Error><RequestId>adbc0bc9-d1e2-5ab7-bd59-5a7a20cb876c</RequestId></ErrorResponse> 

Was dies verursacht? Das bedeutet natürlich, dass ich einen Parameter übergebe, der ungültig ist, aber da Sellerie die SQS-Anfrage generiert, bin ich mir nicht sicher, was das ist. Wie behebe ich das?

Answer 1

Nach this github Ausgabe:

Basically you can't inspect the state of any woker in the cluster.

Aufgrund der Tatsache, dass (from the docs):

SQS doesn’t yet support worker remote control commands.

So jetzt scheint dies nicht möglich zu sein - die beste Wahl (und wie ich gelöst mein Problem, das mich hierher geführt hat) greift wahrscheinlich direkt auf die Warteschlange mit boto3 zu.