1

datetime パラメータを必要とする python スクリプトを実行し、その出力を slack に投稿したいと考えています。しかし、気流テンプレート変数を取得する方法がわかりませんds。

たとえば、以下のコードがあるとします。

def make_txt():
    # get ds
    ds = get_ds()
    ds = ds * 3 + 4 / 5   # do something with ds
    return ds

slack_task = SlackAPIPostOperator(
    text=make_txt(),
    token='xoxp-xxxxxxx',
)

で実行するairflow backfill dag_id -s 2016-10-01ので、ds(ここでは 2016-10-01) はスラック テキストに渡す必要があります。

Pythonスクリプトの出力をファイルに書き込んでから、それを読み取ってスラックテキストに直接渡します。しかし、それは完璧な解決策ではないと思います。

4

1 に答える 1

2

のtextフィールドSlackAPIPostOperatorはテンプレート化されているため{{ ds }}、テキスト内のどこかに追加すると、jinja によって挿入されます。

于 2016-11-29T20:18:18.843 に答える