我正在尝试创建一个Cloud Composer DAG,通过发布/订阅消息触发。下面是谷歌的一个例子,它在云存储存储桶中每次发生变化时都会触发DAG:
然而,在开始时,他们说you can trigger DAGs in response to events, such as a change in a Cloud Storage bucket or a message pushed to Cloud Pub/Sub。我花了很多时间试图弄清楚如何做到这一点,但没有结果。
你能帮我或给我指路吗?谢谢!
我有一个云函数(fce_a),我需要从同一个GCP项目和区域中的另一个云函数(fce_b)调用它。当我将fce_a设置为Allow all traffic (在Ingress settings中)时,它可以完美地工作(使用this method)。但是,当我将fce_a设置为Allow internal traffic only (在Ingress settings中)时,我得到的是Error 403 (Forbidden) 403. That's an error. Access is forbidden. That's all we know. (提到的here)。 我尝