Fluxo de ar: tarefas na fila, mas não em execução
Eu sou novo no fluxo de ar e estou tentando configurá-lo para executar pipelines ETL. Eu consegui instalar
fluxo de arpostgressalsãorabbitmqEu sou capaz de testar executar o turtorial dag. Quando tento agendar os trabalhos, o agendador é capaz de buscá-lo e enfileirar os trabalhos que pude ver na interface do usuário, mas as tarefas não estão em execução. Alguém poderia me ajudar a resolver esse problema? Acredito que estou perdendo o conceito mais básico de fluxo de ar aqui. abaixo está o airflow.cfg
Aqui está o meu arquivo de configuração:
[core]
airflow_home = /root/airflow
dags_folder = /root/airflow/dags
base_log_folder = /root/airflow/logs
executor = CeleryExecutor
sql_alchemy_conn = postgresql+psycopg2://xxxx.amazonaws.com:5432/airflow
api_client = airflow.api.client.local_client
[webserver]
web_server_host = 0.0.0.0
web_server_port = 8080
web_server_worker_timeout = 120
worker_refresh_batch_size = 1
worker_refresh_interval = 30
[celery]
celery_app_name = airflow.executors.celery_executor
celeryd_concurrency = 16
worker_log_server_port = 8793
broker_url = amqp://rabbit:[email protected]/rabbitmq_vhost
celery_result_backend = db+postgresql+psycopg2://postgres:[email protected]:5432/airflow
flower_host = 0.0.0.0
flower_port = 5555
default_queue = default
DAG:Este é o tutorial que eu usei
e a data de início do meu dag é - 'start_date': datetime (2017, 4, 11),