• 手机版

    扫码体验手机版

  • 微信公众号

    扫码关注公众号

国内首家协议开发

软芯音视解码保护平台

在线
客服

发布
需求

在线
聊天

天盟
APP

天盟APP下载

关注
微信

微信扫一扫访问
顶部

Airflow-工作流管理工具,急求!

通过官方文档和一些博客简单的知道了Airflow的使用方式,但是请问一下大神,如果我的Python项目是很多个脚本代码组成的,如何使用Airflow进行管理呢?
我自己目前学习了解到的是,通过在管道中可以通过设置operators(任务)来执行一些bash命令或者脚本以及可以调用Python的一些脚本自定义一些函数处理逻辑,但是具体在项目实践开发的过程中该如何添加到Airflow进行管理呢?
例如:
用Python集成消息中间件,我订阅了一个主题A,然后主题A发布了消息(一些数据),我接受到消息后,对它进行了数据清理,之后存入相应的数据库。以上这个Python写完之后,我如何用Airflow去管理这个脚本呢?
刚开始学习使用airflow这个工具,望大神指导!

免责声明:本内容仅代表回答会员见解不代表天盟观点,请谨慎对待。

版权声明:作者保留权利,不代表天盟立场。

使用道具 举报

发新帖

发布任务需求已有1031167位用户正在使用天盟网服务

发布分类: *
任务预算: *
需求内容: *
手机号码: *
任务商家报价为
  • 预算价 :
  • 成交价 :
  • 完工期 :
  • 质保期 :

* 最终任务项目以服务商报价、双方协商为准!