Trigger airflow dag using python

airflow_trigger_dag.py

import os
import requests
import time
import json

class AirflowTrigger(object):
    def __init__(self, airflow_addr, dag_id, trigger_conf):
        self.airflow_addr = airflow_addr
        self.dag_id= dag_id
        self.trigger_conf = trigger_conf
    
    def exec(self):
        time_stamp = time.strftime('%Y-%m-%dT%H:%M:%SZ')

        payload = {
            "execution_date": time_stamp,
            "conf": self.trigger_conf
        }

        headers = {
            'Cache-Control': 'no-cache',
            'Content-Type': 'application/json'
        }

        url = os.path.join(self.airflow_addr, 'api/experimental/dags/{}/dag_runs'.format(self.dag_id))
        resp = requests.post(url, headers=headers, data=json.dumps(payload))

        return json.loads(resp.text)