Във вашия config.yml
файл, можете ли да пренаредите следните 2 задачи (Airflow | Config | Initialize Airflow Database
&Airflow | Config | Copy basic airflow config file
) до
Airflow | Config | Copy basic airflow config file
Airflow | Config | Initialize Airflow Database
По принцип вашият airflow.cfg.j2
файлът трябва да съдържа низ за връзка с база данни с метаданни като този sql_alchemy_conn = my_conn_string
в [core]
раздел, както е посочено в https://airflow.apache.org /howto/set-config.html#setting-configuration-options
(Проверете го два пъти)
След като вашият конфигурационен файл бъде копиран и initdb
се стартира, той създава всички необходими таблици, необходими за въздушния поток.
- name: Airflow | Config | Initialize Airflow Database
shell: "{{ airflow_executable }} initdb"
args:
chdir: "{{ airflow_home }}"
executable: /bin/bash
become: yes
become_method: sudo
become_user: "{{ airflow_user }}"
- name: Airflow | Config | Copy basic airflow config file
template:
src: airflow.cfg.j2
dest: "{{ airflow_home }}/airflow/airflow.cfg"
owner: "{{ airflow_user }}"
group: "{{ airflow_group }}"
mode: 0640
register: airflow_config
notify:
- restart airflow-webserver
- restart airflow-scheduler
- restart airflow-worker