Python-如何将消息(Json Data)发布到主题?

问题描述 投票:0回答:1

我的目标是将我从Restful api调用中提取的数据发布到我专门创建的主题,使消息显示每个键和值。

# PubSub Vars
    project_id = os.environ.get('PROJECT_ID')
    topic_name = os.environ.get('TOPIC_NAME')
    c_tenant         = os.environ['c_tenant']
    tpsswd           = os.environ['tpsswd']
    c_user           = os.environ['c_user']
    tenant_id        = os.environ['tenant_id']
    publisher = pubsub_v1.PublisherClient()
    topic_path = publisher.topic_path(project_id, topic_name)


def get_callback(f, data):
    def callback(f):
        try:
            print(f.result())
            futures.pop(data)
        except:  # noqa
            print('Please handle {} for {}.'.format(f.exception(), data))

    return callback

verify = True
    url = 'https://%s/Redrock/query' % c_tenant
    headers = {
        'X-NATIVE-CLIENT': 'true',
        'Content-Type': 'application/json',
        'Authorization': 'Bearer %s' % bearer_token
        }

    r = requests.get(url, json={"script": "@/lib/server_user_activity.js"}, headers=headers, verify = verify)
response = json.loads(r)
traffic = json.dumps(response)
    if r.status_code == requests.codes.ok:
        for item in traffic.items:
            Jsonresponse = publisher.publish(topic_path,data =)
            print(key + ':' + value)

Here is the documentation I am following 来自Google,但我没有完全理解它,因为我没有看到任何发布到主题的数据。谁能引导我正确的方向?

json api google-cloud-platform publish-subscribe
1个回答
0
投票
  • 您的主题至少有一个订阅吗? (您需要订阅,否则该消息将被丢弃)
  • 您可以打印出Jsonresponse并查看是否返回错误吗?
© www.soinside.com 2019 - 2024. All rights reserved.