I'm trying to run the following in Python (with pymongo), however I always get the error message:
CursorNotFound: Cursor not found, cursor id: 16172789264
The code that I have (I tried to set "batch_size", but the error message continued):
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)
Any thoughts?