【发布时间】:2016-11-16 18:14:03
【问题描述】:
我正在尝试在 Python(使用 pymongo)中运行以下命令,但是我总是收到错误消息:
CursorNotFound: Cursor not found, cursor id: 16172789264
我的代码(我尝试设置“batch_size”,但错误消息继续):
import pymongo
client = pymongo.MongoClient()
db = client['tese']
carteiras_cvm = db['carteiras_cvm']
pipeline_acoes =[{"$unwind":"$posicao"},
{"$match" : {"posicao.detalhes.Tipo de Aplicação:" : { "$in" : ['Ações','Brazilian Depository Receipt - BDR',
'Ações e outros TVM cedidos em empréstimo','AÇÕES RECEBIDAS EM BONIFICAÇÃO']}}},
{"$project":{"cnpj_fundo":"$cnpj_fundo", "data_carteira":"$data_carteira", "tipo_aplicacao":"$posicao.detalhes.Tipo de Aplicação:","cod_ativo":"$posicao.detalhes.Cod Ativo:","cod_isin":"$posicao.detalhes.Cod ISIN:","cod_isin":"$posicao.detalhes.Cod ISIN:","descricao":"$posicao.detalhes.Descrição:","posicao_final":"$posicao.posicao_final","perc_carteira":"$posicao.perc_carteira","pl_fundo":"$pl_posicao"}}]
def aggregate(db, pipeline):
return [doc for doc in carteiras_cvm.aggregate(pipeline).batch_size(5)]
resultados_acoes = aggregate(carteiras_cvm, pipeline_acoes)
有什么想法吗?
【问题讨论】:
-
你的光标超时了,看下面的回答:stackoverflow.com/a/24200795/4273834