معرفی شرکت ها
airflow-docker-2.1.1
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
An opinionated implementation of exclusively using airflow DockerOperators for all Operators
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | airflow-docker-2.1.1 |
| نام | airflow-docker |
| نسخه کتابخانه | 2.1.1 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | Hunter Senft-Grupp |
| ایمیل نویسنده | huntcsg@gmail.com |
| آدرس صفحه اصلی | https://github.com/huntcsg/airflow-docker |
| آدرس اینترنتی | https://pypi.org/project/airflow-docker/ |
| مجوز | Apache License 2.0 |
airflow-docker
==============
[](https://circleci.com/gh/airflowdocker/airflow-docker)
[](https://www.codacy.com/app/fool.of.god/airflow-docker?utm_source=github.com&utm_medium=referral&utm_content=huntcsg/airflow-docker&utm_campaign=Badge_Grade)
[](https://codecov.io/gh/airflowdocker/airflow-docker)
Description
-----------
An opinionated implementation of exclusively using airflow
DockerOperators for all Operators.
Default Operator
----------------
``` python
from airflow_docker.operator import Operator
task = Operator(
image='some-image:latest',
...
)
```
Default Sensor
--------------
``` python
from airflow_docker.operator import Sensor
sensor = Sensor(
image='some-image:latest',
...
)
```
Task Code
``` python
from airflow_docker_helper import client
client.sensor(True)
```
Branch Operator
---------------
Dag Task
``` python
from airflow_docker.operator import BranchOperator
branching_task = BranchOperator(
image='some-image:latest',
...
)
```
Task Code
``` python
from airflow_docker_helper import client
client.branch_to_tasks(['task1', 'task2'])
```
Short Circuit Operator
----------------------
Dag Task
``` python
from airflow_docker.operator import ShortCircuitOperator
short_circuit = ShortCircuitOperator(
image='some-image:latest',
...
)
```
Task Code
``` python
from airflow_docker_helper import client
client.short_circuit() # This task will short circuit if this function gets called
```
Context Usage
-------------
Dag Task
``` python
from airflow_docker.operator import Operator
task = Operator(
image='some-image:latest',
provide_context=True,
...
)
```
Task Code
``` python
from airflow_docker_helper import client
context = client.context()
```
Configuration
-------------
The following operator defaults can be set under the `airflowdocker`
namespace:
- force\_pull (boolean true/false)
- auto\_remove (boolean true/false)
- network\_mode
For example, to set `force_pull` to False by default set the following
environment variable like so:
``` bash
export AIRFLOW__AIRFLOWDOCKER__FORCE_PULL=false
```
Plugin
======
This package works as an airflow plugin as well. When installed and
running airflow, dags can import like so
``` python
from airflow.{type, like "operators", "sensors"}.{name specificed inside the plugin class} import *
```
i.e.
``` python
from airflow.operators.airflow_docker import Operator
```
Tests
-----
We also ship an `airflowdocker/tester` image to verify the integrity of
your DAG definitions before committing them.
One can run the tests against your own dags like so:
``` bash
docker run -it -v "${pwd}/dags:/airflow/dags" airflowdocker/tester
```
or else see the
[airflow-docker-compose](https://github.com/airflowdocker/airflow-docker-compose)
project which ships with a `test` subcommand for precisely this purpose.
نیازمندی
| مقدار | نام |
|---|---|
| ==1.10.9 | apache-airflow[celery,docker] |
| >=0.2.0 | airflow-docker-helper |
| ==0.1.4 | airflow-queue-stats |
| - | boto3 |
| >=1.1 | releasely |
| - | sphinx |
| - | sphinx-rtd-theme |
| - | isort |
| - | black |
| - | flake8 |
| - | pytest |
| - | pytest-cov |
| - | mock |
زبان مورد نیاز
| مقدار | نام |
|---|---|
| >=3,!=3.0.*,!=3.1.*,!=3.2.*,!=3.3.*,!=3.4.*,!=3.5.* | Python |
نحوه نصب
نصب پکیج whl airflow-docker-2.1.1:
pip install airflow-docker-2.1.1.whl
نصب پکیج tar.gz airflow-docker-2.1.1:
pip install airflow-docker-2.1.1.tar.gz