1
我试图让问题与亚马逊SQS一起工作,但任务未运行。但是我的任务运行在开箱即用的RabbitMQ你如何获得亚马逊SQS与Django芹菜
下面是我曾尝试(等等)的链接
https://www.caktusgroup.com/blog/2011/12/19/using-django-and-celery-amazon-sqs/
他们似乎相当过时。我暗示我不要收到任何消息,当我登录到亚马逊的控制台,但我看到芹菜日志的活动表明他们正在与亚马逊沟通
DEBUG b'<?xml version="1.0"?><ReceiveMessageResponse xmlns="http://queue.amazonaws.com/doc/2012-11-05/"><ReceiveMessageResult/><ResponseMetadata><RequestId>f8d10c14-99f7-520b-a58d-5d2cc203ad8b</RequestId></ResponseMetadata></ReceiveMessageResponse>'
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Method: GET
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Path: /967610578225/transfer_files
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Data:
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Headers: {}
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Host: eu-west-1.queue.amazonaws.com
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Port: 443
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Params: {'Version': '2012-11-05', 'Action': 'ReceiveMessage', 'WaitTimeSeconds': 0, 'MaxNumberOfMessages': 4}
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG Token: None
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log DEBUG CanonicalRequest:
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log GET
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log /967610578225/transfer_files
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log Action=ReceiveMessage&MaxNumberOfMessages=4&Version=2012-11-05&WaitTimeSeconds=0
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log host:eu-west-1.queue.amazonaws.com
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log x-amz-date:20170307T065652Z
Mar 7 08:56:52 ip-172-31-41-253 e-celery-worker.log
, 'Authorization': 'AWS4-HMAC-SHA256 Credential=xxxxxx/20170307/eu-west-1/sqs/aws4_request,SignedHeaders=host;x-amz-date,Signature=xxxxxx', 'User-Agent': 'Boto/2.45.0 Python/3.4.3 Linux/4.1.17-22.30.amzn1.x86_64', 'X-Amz-Date': '20170307T065652Z'}
Mar 7 08:56:52 ip-172-31-41-253 eright-celery-worker.log DEBUG Response headers: [('Server', 'Server'), ('Date', 'Tue, 07 Mar 2017 06:56:52 GMT'), ('Content-Type', 'text/xml'), ('Content-Length', '240'), ('Connection', 'keep-alive'), ('x-amzn-RequestId', 'bbad9a79-f65e-568d-aaeb-cb41adaa390d')]
我的设置
BROKER_TRANSPORT = 'sqs'
BROKER_TRANSPORT_OPTIONS = {
'region': 'eu-west-1',
'polling_interval': 2,
'visibility_timeout': 3600,
}
BROKER_USER = 'xxx'
BROKER_PASSWORD = 'xxxxx/xxxx'
CELERY_IMPORTS = (
'apps.files.tasks',
)
CELERY_QUEUES = {
'default': {
'binding_key': 'default'
},
# Files
'files_copy_paste': {
'binding_key': 'files.copy.paste'
},
}
任何帮助将极大地赞赏
嗨@Isaac,问题是我需要为S3设置AWS_ACCESS_KEY_ID和AWS_SECRET_ACCESS_KEY,所以我使用s3用户访问。而对于经纪人我asumed BROKER_USER ='xxx' BROKER_PASSWORD ='xxxxx/xxxx'是我把我的访问密钥和ID。你把这个区域放在前面的点是我没有尝试过的唯一的东西,我会马上得到它,并让你知道它是否有效 –
@TawandaMinya嘿,它的工作? :)如果是这样,请接受我的回答。 –
嗨,还没有机会测试呢。但是,当我确定将 –