2016-12-09 1 views
2

나는 장고 응용 프로그램에서 SQS와 셀러리를 실행하고 있습니다 :Celery 4.0.0 + Amazon SQS -> "자격 증명의 유효 범위는 '대기열'이 아니어야합니다."

것은 내가 좋아하는 브로커 설정에서 지역을 지정하고시 :

CELERY_BROKER_URL = 'sqs://' 
CELERY_BROKER_TRANSPORT_OPTIONS = { 
    'region': 'eu-west-1', 
    'polling_interval': 3, 
    'visibility_timeout': 300, 
    'queue_name_prefix':'dev-celery-', 
} 

내가 아마존 SQS에서 만든 큐를 볼 수 있지만 같은 시간에 내가 오류를 다음 한 내가 노동자를 발사하려고 할 때.

[2016-12-09 16:06:41,206: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection... 
Traceback (most recent call last): 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/celery/worker/consumer/consumer.py", line 318, in start 
blueprint.start(self) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/celery/bootsteps.py", line 119, in start 
step.start(parent) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/celery/worker/consumer/consumer.py", line 584, in start 
c.loop(*c.loop_args()) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/celery/worker/loops.py", line 88, in asynloop 
next(loop) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/hub.py", line 345, in create_loop 
cb(*cbargs) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/http/curl.py", line 111, in on_readable 
return self._on_event(fd, _pycurl.CSELECT_IN) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/http/curl.py", line 124, in _on_event 
self._process_pending_requests() 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/http/curl.py", line 130, in _process_pending_requests 
self._process(curl) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/http/curl.py", line 178, in _process 
buffer=buffer, effective_url=effective_url, error=error, 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/promises.py", line 146, in call 
svpending(*ca, **ck) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/promises.py", line 139, in call 
return self.throw() 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/promises.py", line 136, in call 
retval = fun(*final_args, **final_kwargs) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/funtools.py", line 100, in _transback 
return callback(ret) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/promises.py", line 139, in call 
return self.throw() 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/promises.py", line 136, in call 
retval = fun(*final_args, **final_kwargs) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/funtools.py", line 98, in _transback 
callback.throw() 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/vine/funtools.py", line 96, in transback 
ret = filter(*args + (ret,), **kwargs) 
File "/home/ubuntu/virtualenvs/env/lib/python3.5/site-packages/kombu/async/aws/connection.py", line 269, in _on_list_ready 
raise self._for_status(response, body) 
boto.exception.SQSError: SQSError: 403 Forbidden 
SenderSignatureDoesNotMatchCredential should be scoped to a valid region, not 'queue'. 
[2016-12-09 16:06:41,260: INFO/MainProcess] Connected to sqs://localhost// 

는 셀러리의 버그가 그래서는 issue at git을 만든 될 수 있습니다. Celery는 SQS 용 레거시 엔드 포인트를 사용합니다. 새로운 종단점은 at Amazon입니다.

그렇지 않은 경우 솔루션을 게시하십시오.

답변

0

나는 here

버그 BOTO에없는 업데이트 endpoints.json 관련이 답을 발견했다. Pull request은 이미 생성되었지만 병합되지 않았습니다.

해결 방법으로 boto에 대한 개인 endpoints.json 파일을로드하는 것이 가능합니다. 이를 위해서는 BOTO_ENDPOINTS 환경 변수에 파일의 경로를 지정하고 풀 요청에서 수정 된 파일을로드해야합니다.

끝점을 수정 한 후에 문제를 해결했습니다.

관련 문제