我一共有三个云函数,第一个云函数,它有一些条件,如果条件为真,那么它应该触发第二和第三云函数,并在触发它们之前将所需的参数或参数传递给第二和第三云函数。我已经尝试了三种不同的执行方式,但是在执行上面的场景时我需要帮助。
云函数--python中的1段代码:
def main(request):
dest_table_name = 'my_dest_table'
myquery = "select count(*) size from `myproject.mydataset.mytable`"
client = bigquery.Client()
job = client.query(myquery)
result = job.result()
for row in results:
print("Total rows available: ",row.size)
if row.size != 0:
pass "dest_table_name" to 2nd cloud function and execute it.
pass "dest_table_name" to 3rd cloud function and execute it.
else:
print("query result is empty")发布于 2019-10-13 13:36:31
你的选择是:
requests.get(<your function URL>)和传递参数作为PubSub主题,并让函数生成/使用PubSub消息;或者:后者的开销将大大减少,但可能会导致更长的整体功能运行时。
发布于 2019-10-14 08:56:49
根据您的详细信息和要求,我建议您使用PubSub并执行以下操作
过程。
顺便说一句,您不是耦合的,您是可伸缩的,您是并行的。
https://stackoverflow.com/questions/58362694
复制相似问题