공기 흐름 ยกเลิก ได้ ได้ การ ใช้ งาน 실험용 휴식 api ไป ตั้ง แต่ แต่ v2.0.0 ด้วย เหตุผล ว่า 실험적 ไม่ มี การ การ ควบคุม การ การ เข้า ถึง ถึง ได้ เกิด เกิด 공기 흐름 API (1.0.0) ขึ้น มา ดูเพิ่มเติม

مาทดลอง ใช้กัน

สิ่งที่ต้องมี

우체부

인증하기

auth_backend 실행airflow.cfg

[api]
auth_backend = airflow.api.auth.backend.basic_auth

เราจำเป็นจะต้องเปิดการใช้ 인증 API v1 จะปฏิเสธการ้องขอ (PermissionDenied) วย่า ลดม

URL 주소 Postman

นกรณีที่ URL ของ เราเป็น Localhost ในการ 트리거 จะใช้ HTTP Methods:POST

http://localhost:8080/api/v1/dags/{DAG_ID}/dagRuns

กำหนด 인증

유형 เป็น 기본 인증 และ 사용자 이름/비밀번호 ต้อง ถูกสร้างอยู่ใน 공기 흐름

กำหนด 헤더

KEY: Content-Type VALUE: application/json

바디

ระบุเป็น raw ประเภท JSON ใส่ค่า {}

응답

답변

{
    "conf": {},
    "dag_id": "covid19_daily",
    "dag_run_id": "manual__2021-02-25T10:04:41.703172+00:00",
    "end_date": null,
    "execution_date": "2021-02-25T10:04:41.703172+00:00",
    "external_trigger": true,
    "start_date": "2021-02-25T10:04:41.708731+00:00",
    "state": "running"
}

ก็จะพบว่า 웹 UI ก็จะพบว่า DAG ของ เราราน แล้ว เปงนการทำานแบบ 매뉴얼


웹 ของ Airflow ก็จะมีคำอธิบาย วิธีการใช้งาน api ต่างๆให้ดู

Airflow REST API에 대해 자세히 알아보기

https://airflow.apache.org/docs/apache-airflow/2.0.1/stable-rest-api-ref.html#section/Overview