当我运行以下代码时,出现错误:http_conn_id http_default未定义
:
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值应该是什么?谢谢
https://example.com/name/1
发出 GET 请求,那么我将创建一个conn_var = https://example.com
和simpleHttpOperator endpoint = /name/1
。 - Aseemhttp_conn_id
。如果你想要对https://example.com/name/1
进行GET请求,则输入主机名为https://example.com
,并在你的任务中将endpoint
设置为/name/1
。 - kaxil