如何在 Airflow 中使用 SimpleHttpOperator

Question

我收到错误：http_conn_id http_default isnt defined 当我运行以下代码时：

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2020, 2, 27),
    'email': ['ss@asd.com'],
    'email_on_failure': True,
    'email_on_retry': True,
    'retries': 1,
    'retry_delay': timedelta(seconds=5),
}
dag = DAG(
    'dag1',
    default_args=default_args,
    description='A simple tutorial DAG',
    schedule_interval='@daily',
)
t2 = SimpleHttpOperator(
    task_id='get_labrador',
    method='GET',
    http_conn_id='http_default',
    endpoint='api/breed/labrador/images',
    headers={"Content-Type": "application/json"},
    xcom_push=True,
    dag=dag
)

我的 http_conn_id 值应该是多少。谢谢

Answer 1

http_conn_id应包含 Airflow Connection的名称，其中包含要连接的 url 的详细信息。例如，发送到 Slack Webhook 的主机名是https://hooks.slack.com/