로컬 컴퓨터의 LocalExecutor에서 CeleryExecutor로 전환하려고합니다. pip install airflow[celery]을 사용하여 필요한 라이브러리를 설치해야합니다. 또한 redis가 설치되어 실행 중입니다. 내가 백그라운드에서 실행 레디 스에 redis://localhost:6379에 broker url 및 celery_result_backend 두 세트가공기 흐름 [셀러리]을 설치 한 후에도 'CeleryExecutor'가 정의되지 않았습니다.
DEFAULT_EXECUTOR = CeleryExecutor()
NameError: CeleryExecutor' is not defined
: 나는 airflow worker를 실행하려고하면
그러나, 나는 오류가 발생합니다. 내가 도대체 뭘 잘못하고있는 겁니까?
시도 개방 공기 흐름 설치하고이 실행되는 파이썬 쉘 :
>>> from airflow.executors.celery_executor import CeleryExecutor
난 당신이 더 유용한 오류가 발생합니다 생각합니다.
내가 같은 오류가 어떻게 작동하는지에 대한 문제 : 'DEFAULT_EXECUTOR = CeleryExecutor() NameError : name 'CeleryExecutor'가 정의되지 않았습니다. 사실 약간 원형으로 보입니다 – user3776598
'수입 샐러리'를 시도한다면 어떨까요? 다음에 오류가 있습니까? –
'셀러리 가져 오기 '가 효과가 있습니다. 나는 그것을 작동시키는 것을 끝내었다. '공기 흐름 웹 서버', '공기 흐름 스케줄러', '공기 흐름 작업자'의 순서처럼 보인다. – user3776598
전환 한 것처럼 보이지만, 공기 흐름으로는 알 수 없습니다. 각 공기 흐름 명령을 실행하기 전에 AIRFLOW_HOME env 변수를 지정했는지 그리고 ~/airflow 및 ~/airflow.cfg (기본값으로 사용됨) 폴더가 없는지 확인하십시오. (귀하의 은 AIRFLOW_HOME을 무시함). 이 문제에 대한
자세한 내용은 : https://github.com/puckel/docker-airflow/issues/132
~/airflow.cfg에'executor = CeleryExecutor'를 설정했습니다. 공기 흐름을 위해 셀러리 작업자를 켜지 않습니까? – user3776598
보인다 공기 흐름 웹 서버, 공기 흐름 스케줄러, 공기 흐름'의 순서 worker'이 – user3776598