【发布时间】:2019-02-05 09:18:12
【问题描述】:
使用 PYthon SDK 将消息发布到 GCP Pub/SUb。代码在 GKE 上的 Kubernetes POD 中运行。
import pymysql
import os
import argparse
import time
from google.cloud import pubsub_v1
entries = ['jelly']
def publish_messages(project, topic_name):
publisher = pubsub_v1.PublisherClient()
topic_path = publisher.topic_path(project, topic_name)
for n in entries:
data = u'Message number {}'.format(n)
data = data.encode('utf-8')
publisher.publish(topic_path, data=data)
print "Message %s sent to queue" % n
脚本在手动执行时工作正常。但是,通过 Crontab 触发时会失败。
Error: No handlers could be found for logger google.cloud.pubsub_v1.publisher._batch.thread"
【问题讨论】:
-
还要检查主题名称和项目名称。如果它不正确,那么它也会给出这个错误。
标签: python-2.7 cron google-cloud-platform google-cloud-pubsub google-kubernetes-engine