在本地测试Google Cloud PubSub推送端点

Question

试图找出在本地测试PubSub推送端点的最佳方法.我们尝试使用ngrok.io,但您必须拥有该域才能进行白名单(这样做的工具也会被破坏...导致无限重定向循环).我们还尝试在本地模拟PubSub.我能够发布和拉取,但我不能让推送订阅工作.我们正在使用像这样的本地Flask网络服务器:

@app.route('/_ah/push-handlers/events', methods=['POST'])
def handle_message():
    print request.json
    return jsonify({'ok': 1}), 200

以下产生无结果:

client = pubsub.Client()
topic = client('events')
topic.create()
subscription = topic.subscription('test_push', push_endpoint='http://localhost:5000/_ah/push-handlers/events')
subscription.create()
topic.publish('{"test": 123}')

当我们尝试创建对HTTP端点的订阅时,它会对我们大喊大叫(如果您不使用HTTPS,则会显示实时PubSub).也许这是设计的？Pull工作得很好......关于如何最好地开发PubSub的任何想法在本地推送端点？

Answer 1

这可能是模拟器中的一个已知错误（即将修复），其中与订阅一起创建的推送端点不起作用。该错误仅影响初始推送配置；修改现有订阅的推送配置应该可行。你能尝试一下吗？