问题
问题
发展环境
诚挚的问候,
发布于 2019-01-14 17:03:18
云任务是异步精心设计。正如您提到的,最好的方法是将它们与云调度器配对。
首先,由于云Scheduler需要一个Pub/Sub或HTTP端点,一旦它运行了作业,它就会调用,所以我建议您创建一个App处理程序,将调用它来创建和发送任务。
您可以通过遵循这个文档来做到这一点。首先,您必须使用创建队列,然后我建议您部署具有创建任务的处理程序的简单应用程序。一个小例子:
from google.cloud import tasks_v2beta3
from flask import Flask, request
app = Flask(__name__)
@app.route('/createTask', methods=['POST'])
def create_task_handler():
client = tasks_v2beta3.CloudTasksClient()
parent = client.queue_path('YOUR_PROJECT', 'PROJECT_LOCATION', 'YOUR_QUEUE_NAME')
task = {
'app_engine_http_request': {
'http_method': 'POST',
'relative_uri': '/handler_to_call'
}
}
response = client.create_task(parent, task)
return response其中'relative_uri‘是任务将调用的处理程序,并处理数据。
完成后,遵循云计划程序文档以创建就业机会,并指定目标为App Engine HTTP,将URL设置为'/createTask',将服务设置为以哪个处理URL,而将HTTP设置为POST。根据需要填充其余的参数,您可以将频率设置为“每个星期一09:00”。
https://stackoverflow.com/questions/54155532
复制相似问题