не удается увидеть DAG в веб-интерфейсе - PullRequest
Новая
       25

не удается увидеть DAG в веб-интерфейсе

0 голосов
/ 09 июля 2019

Я создал новый DAG, используя следующий код.Он вызывает скрипт Python.

Код: 

    from __future__ import print_function
    from builtins import range
    import airflow
    from airflow.operators.python_operator import PythonOperator
    from airflow.models import DAG
    from airflow.operators.bash_operator import BashOperator
    from airflow.operators.dummy_operator import DummyOperator

    args = {
        'owner': 'admin'
    }

    dag = DAG(
        dag_id='workflow_file_upload', default_args=args,
        schedule_interval=None)

    t1 = BashOperator(
        task_id='testairflow',
        bash_command='python /root/DataLake_Scripts/File_Upload_GCP.py',
        dag=dag)

Я поместил его в папку $ airflowhome / dags.

после того, как я запустил:

планировщик воздушного потока

Я пытаюсь увидеть DAG в WebUI, но там его нет.Ошибка не приходит.

1 Ответ

0 голосов
/ 11 июля 2019

Я встречал ту же проблему.
Я понял, что проблема в исходной базе данных sqlite.Я предполагаю, что это какая-то особенность воздушного потока 1.10.3

В любом случае, я решил проблему с помощью бэкэнда postgresql.
Эти ссылки помогут вам:

Все инструкции подходят для Python 3.
Вы увидите свою группу обеспечения доступности баз данных после выполнения команд «airflow webserver» и «airflow scheduler».
Также обратите внимание, что вам следует вызвать'sudo service postgresql restart' точно перед командой 'airflow initdb'.

...