Как написать правильный формат запроса от Mongodb для панд DF по Pymongo - PullRequest
Новая
       6

Как написать правильный формат запроса от Mongodb для панд DF по Pymongo

0 голосов
/ 30 января 2019

Я хочу читать данные из mongoDB в pandas dataframe через pymongo, поэтому я использую следующую функцию: 

def read_mongo(db, collection, query={}, host='localhost', port=27017, username=None, password=None, no_id=True):
""" 从Mongo读取并存储到DataFrame """
#连接MongoDB
db = _connect_mongo(host=host, port=port, username=username, password=password, db=db)
#对特定的数据库和集合进行查询
cursor = db[collection].find(query)
#读取数据并构造DataFrame
df =  pd.DataFrame(list(cursor))
#删除MongoDB中主键_id
if no_id:
    del df['_id']
return df

однако я не знаю, как написать запрос в pymongo.Поэтому, когда я написал код ниже, происходит ошибка. 

query =  {"ans_count":{$gte:100}
read_mongo(mydb,collection,query = query, port=27017, username=None, password=None, no_id=True)

Ошибка выглядит следующим образом: 

    File "<ipython-input-85-41c57b2616f6>", line 1
query =  {"ans_count":{$gte:100}}
                    ^
    SyntaxError: invalid syntax

Кажется, что написанный мной запрос вызывает некоторые синтаксические ошибки. Но как можноЯ корректирую запрос для успешного получения данных из моей базы данных?

...