어딘가에 단계가 빠져 있다고 생각하지만 주위를 둘러 보았고 찾을 수 없었습니다. 셀러리 작업을 실행할 때 get_task.delay(args)을 호출하면이 오류 메시지 no encoder installed for (u'json',)이 발생합니다. 내 자신의 사용자 지정 serialization을 가지고 있다고 가정합니까? settings.py CELERY_
플라스크로 새로 시작했으며 일부 요청을 처리 할 서버 응용 프로그램을 만들고 있습니다. 이제는 POST 요청 부분에 시간이 걸리는 프로세스가 있습니다. 내가 보낸 첫 번째 POST 요청에 응답 할 때까지 모바일 앱에서 사용자를 대기시켜야합니다. OK을 모바일 앱에 반환하고 백그라운드에서 데이터를 처리 할 수있는 방법이 있습니까? 나는 같은 것까지 생각 무엇
내 알림 모델에 send_time 필드가 있습니다. 그 당시 모든 모바일 클라이언트에게 알림을 보내려고합니다. 내가 뭘, 내가이 작업을 생성 tasks.py 분마다 @app.task(name='app.tasks.send_notification')
def send_notification():
# here is logic to filter notif
mod_wsgi 데몬 프로세스를 사용하여 테스트 장고 사이트를 가지고 있고 연락처 양식을 전자 메일로 보내고 감독자를 설치하는 간단한 셀러리 작업을 설정했습니다. 장고 코드가 정확한지 알고 있습니다. 내가 가지고있는 문제는 양식을 제출할 때 첫 번째 메시지 만 받는다는 것입니다. 이후에 연락 양식을 작성해도 전혀 메시지가 보내지지 않습니다. 내 서버에는 D
나는 실패한 작업을 실행 다시하지 않는 다음과 같은 내용으로 간단한 test_celery.py 파일이 $ python test_celery.py
Tring: 0/3
Traceback (most recent call last):
File "test_celery.py", line 20, in <module>
my_fail()
Fi
기본적으로 별도의 스레드에서 서버 측에서 이벤트를 생성하려고합니다. 이벤트를 방출해야하는 celery.task이 있지만 해당 코드는 실행되지 않습니다. import json
import time
from celery import Celery
from flask import Flask
from flask import jsonify
from fla
클라이언트 - 서버 통신을 위해 웹 소켓을 사용하는 django-channels + celery로 작성된 webapp가 있습니다. daphne, 셀러리 작업자와 redis를 호스트 시스템에서 실행하여 테스트 한 후, 모든 것을 도커로 캡슐화하여 배치 가능한 시스템을 구성하기로 결정했습니다. 여기가 문제가 시작된 곳입니다. 필자는 docler-compose.
내가 잘못 설계 한 Flask 응용 프로그램을 가지고 있을지도 모르는 고차원 질문이지만, 사용자가 양식을 제출 한 후 셀러리 작업자가 입력을 SQL 쿼리 형식으로 변환하고 해당 쿼리를 실행하는 응용 프로그램을 작성했습니다. 결과를 유지하기 위해 Redis 백엔드를 설정 했으므로 작업이 완료되면 Redis에서 결과를 표시 할 수 있습니다. 그러나 이러한 결과