airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <>
Subject [jira] [Commented] (AIRFLOW-654) SSL for AMQP w/ Celery(Executor)
Date Thu, 01 Jun 2017 08:20:04 GMT


ASF subversion and git services commented on AIRFLOW-654:

Commit 868bfe4cab91e306f450b8560915918351af341c in incubator-airflow's branch refs/heads/master
from [~michaelotte1]
[;h=868bfe4 ]

[AIRFLOW-654] Add SSL Config Option for CeleryExecutor w/ RabbitMQ
- Add BROKER_USE_SSL config to give option to send AMQP messages over SSL
- Can be set using usual airflow options (e.g. airflow.cfg, env vars, etc.)

Closes #2333 from forsberg/ssl_amqp

> SSL for AMQP w/ Celery(Executor)
> --------------------------------
>                 Key: AIRFLOW-654
>                 URL:
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: celery, executor
>    Affects Versions: Airflow 2.0, Airflow 1.8
>         Environment: Tested on:
> Airflow, celery[auth] 4.0,
>            Reporter: Michael Otte
>              Labels: patch, security
>             Fix For: Airflow
> Add celery ssl certs for amqp (w/ rabbitmq) encryption.  This can go in
and set with current airflow configuration practices (e.g. explicit in airflow.cfg, env var,
> tldr
> Currently, celery's AMQP messages cannot be encrypted using SSL unless a SSH tunnel,
VPN, or an alternative network encryption protocol is used.
> This is the only feature addition required to be able to use Airflow in an end-to-end
encrypted, distributed system.
> The webserver, the disk volume, etc. can be encrypted outside of Airflow with good security
practices (e.g. the webserver can be secured at the proxy layer, GCM with AES can be used
for in-state encryption, etc.) 
> Could technically use the certs from the webserver (link to commit/issue comment below)
if you're lazy and if the certs are issued from the same certificate authority as the broker's

This message was sent by Atlassian JIRA

View raw message