airflow + mysql

Posted 木心

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了airflow + mysql相关的知识,希望对你有一定的参考价值。

1.centos7.8安装 mysql 5.7

参考:CentOS7安装MySQL(完整版)

 

2.mysql-airflow

在mysql上执行

create database airflow; —— 创建数据库

GRANT all privileges on airflow.* TO airflow@% IDENTIFIED BY 123456; —— 将数据库airflow的所有权限授权airflow用户,密码123456且该用户可在任何IP段登录操作

FLUSH PRIVILEGES; —— 刷新权限

set explicit_defaults_for_timestamp = 1;
on airflow.*:表示airflow数据库的所有表的权限

修改airflow配置文件airflow.cfg

executor = LocalExecutor
sql_alchemy_conn = mysql://airflow:123456@mysqlIP/airflow

 

初始化数据库

airflow initdb

若之前使用sqllite初始化过可使用airflow resetdb

重启 scheduler 即可(默认并发调度16)

 

参考:

  1) CentOS7安装Airflow

  2)Airflow安装与简单使用

  3)airflow 安装,部署,填坑

 

---

以上是关于airflow + mysql的主要内容,如果未能解决你的问题,请参考以下文章

airflow + mysql

(Django)气流中的 ORM - 有可能吗?

airflow使用mysql数据库,LocalExecutor并发调度

Airflow 2.2.3 + MySQL 8.0.27 + Redis 6.2 部署Airflow任务调度平台

Airflow使用笔记

Airflow 入门及使用