Skip to content

Instantly share code, notes, and snippets.

View rssanders3's full-sized avatar
πŸƒβ€β™‚οΈ

Robert Sanders rssanders3

πŸƒβ€β™‚οΈ
View GitHub Profile
pip install apache-airflow=={AIRFLOW_VERSION}
pip install apache-airflow[hive]=={AIRFLOW_VERSION}
pip install apache-airflow[celery]=={AIRFLOW_VERSION}
[core]
# The executor class that airflow should use. Choices include
# SequentialExecutor, LocalExecutor, CeleryExecutor
executor = CeleryExecutor
[core]
# The SqlAlchemy connection string to the metadata database.
# SqlAlchemy supports many different database engine, more information
# their website
sql_alchemy_conn = mysql://{USERNAME}:{PASSWORD}@{MYSQL_HOST}:3306/airflow
[core]
# Are DAGs paused by default at creation
dags_are_paused_at_creation = True
[core]
# Whether to load the examples that ship with Airflow. It's good to
# get started, but you probably want to set this to False in a production
# environment
load_examples = False
[celery]
# The Celery broker URL. Celery supports RabbitMQ, Redis and experimentally
# a sqlalchemy database. Refer to the Celery documentation for more
# information.
broker_url = amqp://guest:guest@{RABBITMQ_HOST}:5672/
[celery]
# The Celery broker URL. Celery supports RabbitMQ, Redis and experimentally
# a sqlalchemy database. Refer to the Celery documentation for more
# information.
broker_url = sqs://{ACCESS_KEY_ID}:{SECRET_KEY}@
# Note: You will also need to install boto:
$ pip install -U boto
[celery]
# Another key Celery setting
celery_result_backend = db+mysql://{USERNAME}:{PASSWORD}@{MYSQL_HOST}:3306/airflow
[celery]
# Default queue that tasks get assigned to and that worker listen on.
default_queue = {YOUR_QUEUE_NAME_HERE}
pip install cryptography
python -c "from cryptography.fernet import Fernet; print(Fernet.generate_key().decode())"