亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

如何使用 REST API 觸發 Airflow Dag

如何使用 REST API 觸發 Airflow Dag

Go
MMTTMM 2022-05-18 16:40:14
我正在嘗試通過關注https://airflow.apache.org/docs/stable/api.html這個站點來觸發 Airflow Dags。他們提供了一個 curl 命令curl -X POST \  http://localhost:8080/api/experimental/dags/<DAG_ID>/dag_runs \  -H 'Cache-Control: no-cache' \  -H 'Content-Type: application/json' \  -d '{"conf":"{\"key\":\"value\"}"}'來觸發 Dag。當我從我的 Shell 執行此命令時,它正在工作。我試圖在 Go 中調用這個端點POST /api/experimental/dags/<DAG_ID>/dag_runs,我得到了400 Bad Request如何使用POST /api/experimental/dags/<DAG_ID>/dag_runsashttp.POST()或http.NewRequest()在 Go 中?我試過這個:package mainimport (    "encoding/json"    "fmt"    "net/http"    "strings")func main(){    body := strings.NewReader(`{"conf":"{\"key\":\"value\"}"}`)    req, err := http.NewRequest("POST", "http://localhost:8080/api/experimental/dags/airflow_sample/dag_runs", body)    if err != nil {        fmt.Println(err)    }    req.Header.Set("Cache-Control", "no-cache")    req.Header.Set("Content-Type", "application/json")    resp, err := http.DefaultClient.Do(req)    if err != nil {        fmt.Println(err)    }    fmt.Println(resp)    defer resp.Body.Close()}
查看完整描述

1 回答

?
HUWWW

TA貢獻1874條經驗 獲得超12個贊

我解決了。

在主要功能 -

我變了body := strings.NewReader(`{"conf":"{\"key\":\"value\"}"}`)

對此body := strings.NewReader(`{}`)

它就像一個魅力。


查看完整回答
反對 回復 2022-05-18
  • 1 回答
  • 0 關注
  • 104 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號