代码之家 › 专栏 › 技术社区 › Rob

用参数触发Google云导体中的DAG

airflow google-cloud-functions google-cloud-platform

Rob · 技术社区 · 6 年前

https://cloud.google.com/composer/docs/how-to/using/triggering-with-gcf 例如,它允许您根据事件按名称触发dag。您还可以从事件向dag传递一个参数,比如添加到bucket的文件名吗?

1 回复 | 直到 6 年前

vdolez 6 年前

我确实能够用参数从云函数中触发DAG。 Rest API Plugin made by robertsanders

我必须将一个JSON映射作为参数传递给web服务器URL:

const WEBSERVER_URL = 'https://' + WEBSERVER_ID + '.appspot.com/admin/rest_api/api?api=trigger_dag&dag_id=' + DAG_NAME + '&conf=%7B%22fileName%22%3A%22' + fileName + '%22%7D';

然后,在一个PythonOperator中,我得到了映射的文件名条目,如下所示:

def get_file_name_from_trigger(ds, **kwargs):
    return kwargs['dag_run'].conf['fileName']

推荐文章

Jess The Witch · GCP云功能中处理延迟任务的模式

5 月前

Victor · 云运行-经过身份验证的请求在自定义(子)域上不起作用

11 月前

Javier Tan · 建议如何在firebase中存储需要限制字符的字段?

1 年前

Dmitr Zar · Google OAuth 2.0身份验证在React应用程序中不起作用:我做错了什么?

1 年前

Monzur Alam · 在GCP中启动计算VM实例后,我的VM外部IP和SSH不可访问

1 年前

trndjc · 在谷歌云控制台中,将Firebase Admin SDK角色授予默认计算服务帐户是否安全?

1 年前

Junekuan · Google Appsheet未显示Google sheet图像URL列中的图像

1 年前

pnpjtr · 谷歌云SQL/mysql谁是对的?

1 年前

ffejrekaburb · 谷歌云平台Python 3 CURRENT_VERSION_ID

1 年前

Grantie · Firebase说ID不匹配

1 年前