hiplab/data-transport
hiplab
/
data-transport
mirror of https://github.com/lnyemba/data-transport
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bug fix: mongodb commands with values

This commit is contained in:
Steve Nyemba 2020-12-26 12:20:40 -06:00
parent 03e0203c28
commit 7ba09309d3
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
setup.py
View File

@ -8,7 +8,7 @@ def read(fname):
return open(os.path.join(os.path.dirname(__file__), fname)).read() return open(os.path.join(os.path.dirname(__file__), fname)).read()
args = { args = {
"name":"data-transport", "name":"data-transport",
"version":"1.3.0", "version":"1.3.2",
"author":"The Phi Technology LLC","author_email":"info@the-phi.com", "author":"The Phi Technology LLC","author_email":"info@the-phi.com",
"license":"MIT", "license":"MIT",
"packages":["transport"]} "packages":["transport"]}

2
transport/mongo.py
View File

@ -65,6 +65,8 @@ class MongoReader(Mongo,Reader):
out = self.db.command(cmd) out = self.db.command(cmd)
#@TODO: consider using a yield (generator) works wonders #@TODO: consider using a yield (generator) works wonders
while True : while True :
if 'values' in out :
r += out['values']
if 'cursor' in out : if 'cursor' in out :
key = 'firstBatch' if 'firstBatch' in out['cursor'] else 'nextBatch' key = 'firstBatch' if 'firstBatch' in out['cursor'] else 'nextBatch'
else: else: