Wie kann ich `ds` in SlackAPIPostOperator bekommen?

Question

Ich möchte ein Python-Skript ausführen, die einen Datetime-Parameter benötigen und ihre Ausgabe in Slack versetzen. Aber ich weiß nicht, wie Luftstrom Vorlage Variable ds erhalten.

Lassen Sie uns sagen, ich unten Code haben:

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', 
) 

Weil ich mit airflow backfill dag_id -s 2016-10-01 laufen wird, die ds (hier ist 2016.10.01) sollte Text nachzulassen passieren.

Ich versuche, Python-Skript-Ausgabe in eine Datei schreiben und dann lesen und übergeben, um direkt Text zu verlieren. Aber ich denke nicht, dass das eine perfekte Lösung ist.

Answer 1

Das text Feld von SlackAPIPostOperator ist templated, also, wenn Sie {{ ds }} irgendwo innerhalb des Textes hinzufügen, wird es von jinja eingefügt.