创建持久的持续改变Feed

Posted 2021-04-02

我使用Cloudant存储json对象。他们有一个API，可以根据数据库中发生的变化获取连续的Feed。我想要做的是创建一个持久的连接到这个端点，并在每次响应对象更新时调用一个函数（回调）。 Cloudant在Node-js中有一个内置函数，但没有什么能在后台运行python（使用v 2.7）。

我怎么解决这个问题？在网上找不到任何有用的东西。 Cloudant包中的内置函数在我所拥有的Flask API应用程序中不起作用（它们只是使用永不结束的循环来检索更改）。

我的想法是代码看起来像这样：

def callBack(event):
    print(event)

session(url="username:password.cloudant.com/test/_changes?feed=continous", callback=callBack, feed="live")

答案

你需要一个事件循环（节点有内置，Python没有）。我会看看像gevent库这样的东西。

有一个教程显示在这里使用gevent的长轮询：http://sdiehl.github.io/gevent-tutorial/#long-polling应该是可扩展的，以使用流式更改源，如https://github.com/xpqz/pylon/blob/master/pylon.py#L165。