Используя сельдерей с Amazon SQS, сообщения ждут в «доступных сообщениях» ⇐ Python

[Anonymous]

У меня есть проблема с сельдереем. Я использую сельдерей с Amazon SQS. Я установил все о сельдерее и кв. Но они не получают ни одного работника сельдерея. Я полагаю, что я должен увидеть сообщения в разделе «Сообщения в полете». Вот скриншот:

вот мой views.py , где я использую функцию в tasks.py.py.py.py.py.py.py.py.py.py.py.py.py. verify_mail.delay([email protected])

my tasks.py:
from celery import shared_task
from time import sleep
from django.shortcuts import render, redirect, HttpResponse
import boto3

@shared_task
def verify_mail(new_email):

ses = boto3.client('ses')

response = ses.verify_email_identity(
EmailAddress = new_email
)

return None
< /code>
Если я запускаю так: verify_mail ([email protected]), проблем нет. Но когда я запускаю с задержкой (), он не работает.celery -A myProject worker -l INFO --without-gossip --without-mingle --without-heartbeat -Ofair --pool=solo

my celery.py:
import os

from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'myProject.settings')

app = Celery('myProject')

app.config_from_object('django.conf:settings', namespace='CELERY')

app.autodiscover_tasks()

@app.task(bind=True, ignore_result=True)
def debug_task(self):
print(f'Request: {self.request!r}')

my settings.py:
CELERY_BROKER_URL = "sqs://{aws_access_key}:{aws_secret_key}@".format(
aws_access_key=AWS_ACCESS_KEY_ID, aws_secret_key=AWS_SECRET_ACCESS_KEY
)

CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_BROKER_TRANSPORT_OPTIONS = {
'region': 'eu-central-1',
}
CELERY_RESULT_BACKEND = None
CELERY_ENABLE_REMOTE_CONTROL = False
CELERY_SEND_EVENTS = False


Подробнее здесь: https://stackoverflow.com/questions/766 ... -avaliable