适用于 Cloud Scheduler 的连接器
使用集合让一切井井有条
根据您的偏好保存内容并对其进行分类。
定义用于在工作流内访问 Cloud Scheduler 的内置函数的 Workflows 连接器。
深入探索
如需查看包含此代码示例的详细文档,请参阅以下内容:
代码示例
如未另行说明,那么本页面中的内容已根据知识共享署名 4.0 许可获得了许可,并且代码示例已根据 Apache 2.0 许可获得了许可。有关详情,请参阅 Google 开发者网站政策。Java 是 Oracle 和/或其关联公司的注册商标。
[[["易于理解","easyToUnderstand","thumb-up"],["解决了我的问题","solvedMyProblem","thumb-up"],["其他","otherUp","thumb-up"]],[["很难理解","hardToUnderstand","thumb-down"],["信息或示例代码不正确","incorrectInformationOrSampleCode","thumb-down"],["没有我需要的信息/示例","missingTheInformationSamplesINeed","thumb-down"],["翻译问题","translationIssue","thumb-down"],["其他","otherDown","thumb-down"]],[],[],[],null,["# Connector for Cloud Scheduler\n\nWorkflows connector that defines the built-in function used to access Cloud Scheduler within a workflow.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [Cloud Scheduler API Connector Overview](/workflows/docs/reference/googleapis/cloudscheduler/Overview)\n\nCode sample\n-----------\n\n### YAML\n\n # This workflow demonstrates how to use the Cloud Scheduler connector:\n # Create a Pub/Sub topic and subscription for notifications\n # Create a Cloud Scheduler job that runs every minute and publishes\n # a message to the Pub/Sub topic when finished\n # Retrieve message from the subscription and then delete all resources\n # Expected output: \"SUCCESS\"\n - init:\n assign:\n - project_id: ${sys.get_env(\"GOOGLE_CLOUD_PROJECT_ID\")}\n - location_id: \"us-central1\"\n - job_id: \"example-job-id\"\n - topic: \"example-topic-id\"\n - subscription: \"example-subscription-id\"\n - create_topic:\n call: googleapis.pubsub.v1.projects.topics.create\n args:\n name: ${\"projects/\" + project_id + \"/topics/\" + topic}\n - create_subscription_to_topic:\n call: googleapis.pubsub.v1.projects.subscriptions.create\n args:\n name: ${\"projects/\" + project_id + \"/subscriptions/\" + subscription}\n body:\n name: ${\"projects/\" + project_id + \"/subscriptions/\" + subscription}\n topic: ${\"projects/\" + project_id + \"/topics/\" + topic}\n - create_job:\n call: googleapis.cloudscheduler.v1.projects.locations.jobs.create\n args:\n parent: ${\"projects/\" + project_id + \"/locations/\" + location_id}\n body:\n name: ${\"projects/\" + project_id + \"/locations/\" + location_id + \"/jobs/\" + job_id}\n description: \"An example job created by Workflows to test the Cloud Scheduler connector.\"\n schedule: \"* * * * *\" # runs job every minute\n pubsubTarget:\n topicName: ${\"projects/\" + project_id + \"/topics/\" + topic}\n attributes:\n job: \"finished!\"\n - sleep:\n call: sys.sleep\n args:\n seconds: 100 # sleeps for 100 seconds to allow job to run\n - pull_message:\n call: googleapis.pubsub.v1.projects.subscriptions.pull\n args:\n subscription: ${\"projects/\" + project_id + \"/subscriptions/\" + subscription}\n body:\n maxMessages: 1\n - delete_job:\n call: googleapis.cloudscheduler.v1.projects.locations.jobs.delete\n args:\n name: ${\"projects/\" + project_id + \"/locations/\" + location_id + \"/jobs/\" + job_id}\n - delete_subscription:\n call: googleapis.pubsub.v1.projects.subscriptions.delete\n args:\n subscription: ${\"projects/\" + project_id + \"/subscriptions/\" + subscription}\n - delete_topic:\n call: googleapis.pubsub.v1.projects.topics.delete\n args:\n topic: ${\"projects/\" + project_id + \"/topics/\" + topic}\n - the_end:\n return: \"SUCCESS\"\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=workflows)."]]