reactive-programming - 如何使用 Rx 3.1.0v 和 pymongo python 接收 react 性 mongo 数据

Question

我正在尝试使用 Rx 3.1.0 获取可观察的 mongo 数据，我正在尝试实现“Observable.from_”，出现“from_”未被识别为可观察方法的错误

from pymongo import MongoClient
from rx import Observable

def collect_data(dbname, collection):
clt = MongoClient('localhost', 27017)
db = clt[dbname]
col = db[collection]

colData= col.find().limit(10)
return Observable.from_(colData)
collect_data('test', 'money').subscribe(print(data))

出现“from_”未被识别为可观察方法的错误

我正在尝试使用 rx.of

from pymongo import MongoClient
import rx

def collect_data(dbname, collection):
clt = MongoClient('localhost', 27017)
db = clt[dbname]
col = db[collection]

colData= col.find().limit(10)
return rx.of(colData)
collect_data('test', 'money').subscribe(lambda data: print('{0}'.format(data)))

我明白了

<pymongo.cursor.Cursor object at 0x000001BF824FE8C8>

Answer 1

find()返回一个可迭代的游标；所以将它与 for 循环或类似的结合起来使用。例如

for item in colData
    ...

或

list(colData)