回流空气塞

rekcurd-airflow的Python项目详细描述


#回流气流
[![构建状态](https://travis-ci.com/rekcurd/airlow-plugin.svg?branch=master)(https://travis ci.com/rekcurd/Airflow插件)
[![PYPI版本](https://badge.fury.io/py/rekcurd airlow.svg)(https://badge.fury.io/py/rekcurd airlow)
[![codecov](https://codecov.io/gh/rekcurd/Airflow plugin/branch/master/graph/badge.svg)](https://codecov.io/gh/rekcurd/Airflow-plugin“仅限非生成包”)
[![pypi支持的版本](https://img.shields.io/pypi/pyversions/rekcurd airlow.svg)(https://pypi.python.org/pypi/rekcurd airlow)



[rekcurd dashboard]的气流插件(https://github.com/rekcurd/dashboard)

\environment
-python 3.6
-apache airlow>;=1.10.x
-rekcurd dashboard>;=0.4.x

带着自己的价值观。
$cd$aiflow\u home
$aiflow变量-s rekcurd访问令牌$rekcurd访问令牌$rekcurd访问令牌
$aiflow连接-a--conn id rekcurd\u仪表板\
--conn-uri http://$rekcurd\u仪表板主机:$rekcurd\u仪表板端口//

$pip安装rekcurd aiflow
```




br/>您可以看到[此处](./dags)中的插件

([示例dag](./dags/example_evaluation_upload.py))
-modeldeleteoperator。([示例dag](./dags/example_model_delete.py))
-模型求值运算符。([示例dag](./dags/example_model_evaluate.py))
-modelswitchoperator。([示例dag](./dags/example_model_switch.py))
-modelUpdateOperator。([example dag](./dags/example_model_upload.py))

[overall example dag](./dags/example_all.py)


test requirements.txt
$Airflow initdb
$fernet_key=`python-c'来自cryptography.fernet import fernet;print(fernet.generate_key().decode())“`
$sed-i-e”s/\(fernet_key=\).*/\1$fernet_key/”Airflow.cfg

$python-m unittest
```



欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
virtualbox无法从java移动共享文件夹中的文件   java如何连接Android 4.3.5(GA)的apache HttpClient库?   片段中的java Recyclerview未立即显示警报对话框结果   javac(n,r)计算器程序不工作   java使用BooleanQuery还是编写更多索引?   如何在java中设置y/n循环?   java不兼容的通用通配符捕获   java如何在安卓xml中编写数据绑定时的三元操作条件   java如何使用FileDialog?   java如何创建单元测试来检测是否有人使用错误的编码编辑了文件?   java如何从唯一的字符串生成唯一的int?   java gradletomcatplugin:log4j:WARN找不到记录器的附加程序   java我的动态编程解决方案(Kefa和第一步)在codeforces中有什么问题?   java每天更新两个数据库,使它们都包含相同的有效数据集   java如何检查给定的时间是否在时间限制之间   java在单个json POST上保存父级和子级   java如何获取Solr字段类型