bug fix: imports, testing code removed

pull/1/head
Steve L. Nyemba 3 years ago
parent 83cc1778c7
commit 0c0eaf7063

@ -9,6 +9,8 @@ from bson.objectid import ObjectId
from bson.binary import Binary from bson.binary import Binary
import json import json
from datetime import datetime from datetime import datetime
import pandas as pd
import gridfs import gridfs
# from transport import Reader,Writer # from transport import Reader,Writer
import sys import sys

@ -307,20 +307,3 @@ class BQWriter(BigQuery,Writer):
_df.to_gbq(**self.mode) #if_exists='append',destination_table=partial,credentials=credentials,chunksize=90000) _df.to_gbq(**self.mode) #if_exists='append',destination_table=partial,credentials=credentials,chunksize=90000)
pass pass
# import transport
# try:
# _args = {'type':'sql.SQLWriter','args':{'provider':'netezza','host':'ori-netezza.vumc.org','table':'IBM_CCS_DX','username':'nyembsl1','password':'Innovat10n','database':'MALIN_OMOP_RD'}}
# df = pd
# reader = SQLReader(**_args['args'])
# except Exception as error :
# print (error)
# reader = transport.factory.instance(type="sql.BQReader",args={"service_key":"/home/steve/dev/google-cloud-sdk/accounts/curation-prod.json"})
# _df = reader.read(sql="select * from `2019q1r4_combined.person` limit 10")
# writer = transport.factory.instance(type="sql.BQWriter",args={"service_key":"/home/steve/dev/google-cloud-sdk/accounts/curation-prod.json"})
# writer.write(_df,table='2019q1r4_combined.foo')
# write.write()
# _args = {"db":"sample","table":"foo","provider":"postgresql"}
# # # w = SQLWriter(**_args)
# # # w.write({"name":"kalara.io","email":"ceo@kalara.io","age":10})
# r = SQLReader(**_args)
# print (r.read(filter='age > 0',limit = 20))

Loading…
Cancel
Save