Secure and highly available managed workflow orchestration for Apache Airflow. source
- Terrraform (v1.3.1 or higher) install terraform
- AWS Account
$cp .env.example .env
$bash deploy.sh
import requests
import boto3
client = boto3.client('mwaa')
token = client.create_cli_token(Name='<env_name>')
url = f"https://{token['WebServerHostname']}/aws_mwaa/cli"
headers = {
'Authorization' : 'Bearer ' + token['CliToken'],
'Content-Type': 'text/plain'
}
body = 'dags trigger <dag_id>'
requests.post(url, data=body, headers=headers)