我想实现的是,一旦我通过Twilio收到一条消息,我希望计划在恰好5分钟后回复它。我正在使用Google Cloud Functions来生成回复,但我不确定如何安排。我已经经历了云任务,发布/订阅和调度程序,但我仍然对如何实现它感到困惑。我正在使用Python。
我的想法是这样的: Twilio ->云函数收到消息,5分钟后设置一个任务o-> 5分钟后调用另一个云函数。我被困在5分钟后如何安排它。
发布于 2021-03-07 22:49:26
在亚马逊网络服务中,您可以将SQS与delay queues结合使用,这使得这一点非常方便。
Google Cloud Pub/Sub相当于AWS SQS,不支持任何形式的延迟,因此您需要使用Google Cloud Tasks。
当为creating a task时,您可以指定一个schedule time,用于标识应执行任务的时间:
scheduleTime字符串(时间戳格式)
计划尝试或重试任务的时间。
快速示例代码复制&粘贴自Google文档,省略了不相关的部分:
from google.cloud import tasks_v2
from google.protobuf import timestamp_pb2
import datetime
[...]
client = tasks_v2.CloudTasksClient()
parent = client.queue_path(project, location, queue)
in_seconds = 5*60 # After 5 minutes...
d = datetime.datetime.utcnow() + datetime.timedelta(seconds=in_seconds)
timestamp = timestamp_pb2.Timestamp()
timestamp.FromDatetime(d)
task = {
"http_request": {
"http_method": tasks_v2.HttpMethod.POST,
"url": url,
"schedule_time": timestamp,
}
}
# Need to add payload, headers and task name as necessary here...
[...]
response = client.create_task(request={"parent": parent, "task": task})https://stackoverflow.com/questions/66515266
复制相似问题