Датчик SQS в потоке воздуха не срабатывает при появлении нового сообщения - PullRequest
Новая
       117

Датчик SQS в потоке воздуха не срабатывает при появлении нового сообщения

0 голосов
/ 06 августа 2020

Я новичок в Airflow. Я пытаюсь запустить свой даг всякий раз, когда в SQS есть сообщение. Я использую SQSSensor для того же. Он запускается при первом запуске, но после этого он не запускается при появлении нового сообщения.

Пожалуйста, дайте мне знать, если я что-то упустил. 

default_args = {
    'owner': 'Airflow',
    'start_date': days_ago(2),
    'provide_context': True,
}

dag = DAG('sqs_test', default_args=default_args, schedule_interval='@daily')

task = SQSSensor(
    task_id='sqs_test',
    poke_interval=0,
    timeout=10,
    sqs_queue='https://sqs.us-east-1.amazonaws.com/accountid/test',
    aws_conn_id='aws_default',
    max_message=1,
    dag=dag)
...