我的应用程序设计要求一个气流DAG，它目前正在执行，可以暂停，如果执行，恢复，如果暂停和停止。这与提供的暂停/取消暂停功能不同。例如，如果DAG有8个组件，3个组件已经成功执行。现在我想暂停这个DAG的执行。过了一段时间，我想恢复暂停的DAG。在完成了6个组件之后，我意识到这个DAG有一个很大的缺陷，我需要终止它的执行。会要求气流退伍军人对此提出建议。
浏览 0提问于2019-04-16得票数 2
, with Airflow <2.3 AIRFLOW__CELERY__RESULT_BACKEND: db+postgresql://airflow:airflow@postgres/a
浏览 4提问于2022-06-14得票数 0
│ File "/usr/local/lib/python3.6/site-packages/airflow/contrib/executors/kubernetes_executor.py", line│
│ File "/usr/local/lib/python3.6/site-packages/airflow
浏览 5提问于2020-01-22得票数 2
回答已采纳
, with Airflow <2.3 AIRFLOW__CELERY__RESULT_BACKEND: db+postgresql://airflow:airflow@postgres/a
浏览 8提问于2022-09-23得票数 0
回答已采纳
当我安装airflow并将airflow主目录设置为 my_home/Workspace/airflow_home 但当我启动when服务器时，会创建一个新的airflow目录 my_home/airflow我想可能需要更改airflow.cfg文件中的某些内容，但我不是很确定。
浏览 22提问于2020-01-19得票数 0
如果我创建一个airflow_user角色和一个airflow架构。如果我先在airflow模式上授予airflow_user USAGE，然后在所有表上授予SELECT UPDATE INSERT DELETE，这是否足够？该用户是否需要对airflow模式中的所有表使用GRANT ALL？
让airflow_user成为airflow模式的所有者是不是更好?据我所知，这将允许它拥有该模式中的所有权限，因为它是所有者？
浏览 3提问于2018-10-25得票数 4
'3' &airflow-common AIRFLOW__CELERY__RESULT_BACKEND: db+postgresql://airflow:airflow@postgres/
浏览 0提问于2021-10-28得票数 0
/docker-airflow/dags:/usr/local/airflow/dags # Add path for airflow workspace folder
- ./docker-airflow/workd
浏览 8提问于2020-01-17得票数 1
回答已采纳
4回答
我在一个名为tutorial_2.py的文件中定义了一个DAG (实际上是airflow教程中提供的tutorial.py的一个副本，除非dag_id更改为tutorial_2)。当我查看我的默认、未修改的airflow.cfg (位于~/airflow中)时，我看到dags_folder被设置为/home/alex/airflow/dags。我做cd /home/alex/airflow; mkdir dags; cd da
浏览 9提问于2017-07-01得票数 39
回答已采纳
2回答
气流用户问题
、、、
我们已经在虚拟环境中使用sudo根安装了服务帐户上的气流，比如“ABC”，但是我们面临的问题很少。
然后尝试sudo -u ABC python script。由于sudo的使用，没有选择环境变量。在没有环境变量的情况下解决了问题，并且在没有问题的开发环境中运行良好。但是当
浏览 0提问于2019-08-08得票数 1
3回答
/dags:/opt/airflow/dags - ./airflow-logs:/opt/airflow/logsAIRFLOW__CORE__SQL_ALCHEMY_CONN=postgres+psycopg2://<e
浏览 7提问于2021-01-25得票数 7
回答已采纳
1回答
register: airflow_install
pip: version: 1.10.0
- name: Airflow | Install |roles/airflow/files/&qu
浏览 0提问于2018-12-31得票数 1
我有一个PV airflow-pv，它与NFS服务器链接。气流网络服务器和调度器使用的是与airflow-pvc绑定的PVC airflow-pv。]. list of unattached volumes=[airflow-dags airflow-logs airflow-config default-token-hjwth] - name: airflow-config
mountPath: /us
浏览 2提问于2019-08-01得票数 2
回答已采纳
prefix: "airflow."mappings: name: "airflow.job.end" job_name: "$1"
-match: "airflow.operator_failu
浏览 11提问于2022-02-24得票数 2
我可以使用airflow webserver命令正常启动webserver。但是当我使用airflow webserver -D时，它显示： /data/software/miniconda3/lib/python3.7/site-packages/airflow/config_templates/airflow_local_settings.py:65: DeprecationWarning: The elasticsearch_h
浏览 199提问于2019-12-25得票数 0
通常在airflow.cfg中可以这样做，如何将默认的DAG隐藏在坞-组合中？
干杯。
浏览 2提问于2021-10-02得票数 3
回答已采纳
当我运行这些命令时：helm repo add apache-airflow https://airflow.apache.org舵机安装五分钟后停止工作。4m8s
airflow-scheduler-565d8587fd-vm8
浏览 13提问于2021-12-03得票数 1
回答已采纳
/airflow-venv/bin:$PATH"User=airflowType=simple/airflow-venv/bin/activate ; /home/airflow/airflow</em
浏览 2提问于2017-08-24得票数 1
回答已采纳
: Never AIRFLOW__KUBERNETES__DAGS_VOLUME_CLAIM: airflow AIRFLOW__CORE__REMOTE_LOGGING: True
AIRFLOWWORKER_SERV
浏览 0提问于2020-02-13得票数 1
回答已采纳
default_args = { "start_date": airflow.utils.dates.days_ago(1), self._run_command(cur, sql_statement, parameters
浏览 5提问于2022-06-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
