Azkaban自动化调度

不念不忘少年蓝@ 2022-12-22 09:22 141阅读 0赞

1、准备执行的SQL文件（扩展名=.sql）

2、上传SQL文件到Azkaban下的自定义目录

/opt/module/azkaban/pg_sqldir

3、创建Job任务文件（扩展名=.job）

type = command
    command = psql "host=IP地址 port =端口 user = 用户名 password = 密码 dbname=数据库" -f /opt/module/azkaban/pg_sqldir/xxx.sql

4、压缩上面的Job任务文件为同名ZIP格式（扩展名=.zip）

5、通过Azkaban Web页面，创建同名项目。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70][]

6、在项目中上传Job任务（ZIP）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 1][]

6、配置项目调度时间

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 2][]

设置初始化时间，如果不配置，保存不成功，提示：“Error Scheduling Flow”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 3][]

> [https://azkaban.github.io/azkaban/docs/2.5/][https_azkaban.github.io_azkaban_docs_2.5]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70]: /images/20221120/55814943a0284168bd34c9de93d5b76d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 1]: /images/20221120/6f05dadd7af54189ae46e365eaa21df2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 2]: /images/20221120/70020243c29c4dbdb1fbc46670323b06.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201119111556406.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Zpc2hpbmhvdXNl,size_16,color_FFFFFF,t_70
[https_azkaban.github.io_azkaban_docs_2.5]: https://azkaban.github.io/azkaban/docs/2.5/