Есть ли способ создать запланированный запрос с уведомлением pubsub, используя googleapiclient, используя python? - PullRequest
0 голосов
/ 24 января 2020

Я хочу создать динамические c запланированные запросы, используя Python, и я хочу опубликовать sh сообщение в PubSub, когда запрос завершится. Я знаю, что могу сделать это из интерфейса, но это не то, что я ищу.

В настоящее время я делаю это, но поле "messagesPubsubTopi c" игнорируется в запросе

import googleapiclient.http
from googleapiclient import discovery, errors
resource = discovery.build("bigquerydatatransfer", "v1")
body = {
    "notificationPubsubTopic": "projects/{my_project}/topics/{my_topic}",
    "scheduleOptions": {
        "disableAutoScheduling": False
    },
    "disabled": False,
    "displayName": "my_table_name",
    "dataSourceId": "scheduled_query",
    "destinationDatasetId": "test",
    "emailPreferences": {
        "enableFailureEmail": False
    },
    "params": {
        "query": "select 1",
        "write_disposition": "WRITE_TRUNCATE",
        "destination_table_name_template": "table_name_test"
    },
    "schedule": "every day 09:35"
}
creation_job = res.projects().transferConfigs().create(parent=project, body=body)
creation_job.execute()

1 Ответ

0 голосов
/ 20 марта 2020

Google выпустила через несколько дней go новую версию библиотеки datatransfer , добавив поддержку notification_pubsub_topic при создании конфигураций передачи.

...