기류 플러그인을 가져올 수 없습니다.

Question

기류 지침에 따라 here을 따르십시오.

문제 : 웹 서버에서 반환하는 다음과 같은 오류

Broken DAG: [/usr/local/airflow/dags/test_operator.py] cannot import name 
MyFirstOperator 

주 :이 디렉토리 구조는 다음과 같습니다 :

airflow_home 
├── airflow.cfg 
├── airflow.db 
├── dags 
│ └── test_operators.py 
├── plugins 
│ └── my_operators.py 
└── unittests.cfg 

내가 test_operators '에서 플러그인을 가져 시도하고있다 .py '는 다음과 같습니다.

from airflow.operators import MyFirstOperator 

코드는 모두 자습서에있는 코드와 같습니다. 그것은 다음과 같이 수행 기사에서

Answer 1

:

class MyFirstPlugin(AirflowPlugin): 
    name = "my_first_plugin" 
    operators = [MyFirstOperator] 

대신 사용

또한

class MyFirstPlugin(AirflowPlugin): 
    name = "my_first_plugin" 
    operators = [MyFirstOperator] 
    # A list of class(es) derived from BaseHook 
    hooks = [] 
    # A list of class(es) derived from BaseExecutor 
    executors = [] 
    # A list of references to inject into the macros namespace 
    macros = [] 
    # A list of objects created from a class derived 
    # from flask_admin.BaseView 
    admin_views = [] 
    # A list of Blueprint object created from flask.Blueprint 
    flask_blueprints = [] 
    # A list of menu links (flask_admin.base.MenuLink) 
    menu_links = [] 

사용하지 않는 :

from airflow.operators import MyFirstOperator 

According to the airflow article on plugins, it should be:

from airflow.operators.my_first_plugin import MyFirstOperator 

,

그 시도는 작동하지 않는 경우

from airflow.operators.my_operators import MyFirstOperator 

즉, 작동 자세한 내용은 시작시 웹 서버 로그를 확인하지 않습니다.

Answer 2

웹 서버를 다시 시작하면 모든 것이 정상적으로 작동합니다. 여기

가 무슨 일이 있었 것 같아 무엇 :

1. 내가 튜토리얼 예를 시작하기 전에, 나는 내 자신의 플러그인 및 DAG를 실행했습니다. 내가 수정 한 첫 번째 실행에서 사소한 구문 오류가 있었지만 수정 한 후에 '이름을 가져올 수 없음'오류가 발생했습니다.
2. 플러그인 및 dag를 삭제하고 튜토리얼의 내용을 사용하여 진행 상황을 확인했습니다.

내 생각 엔 1 단계 어떻게 든 영향을 2 단계