src.importer.glider_upload Namespace Reference

Functions
	addToMongo (s3_path, file_id, client_id, filepath)
	upload_to_s3 (file, client_id)
	trigger_step_function_ingest (file_id, client_id, file)

Constants
	path = os.path.dirname(sys.argv[0])
	file = sys.argv[1]
	file_id = sys.argv[2]
	client_id = sys.argv[3]
	exchange_rates = sys.argv[4]
	myclient = pymongo.MongoClient(os.environ.get('MONGO_CONNECTION'))
	mydb = myclient["myFirstDatabase"]
	mycol = mydb["files"]

Function Documentation

addToMongo()

src.importer.glider_upload.addToMongo	(		s3_path,
			file_id,
			client_id,
			filepath )

Definition at line 23 of file glider_upload.py.

trigger_step_function_ingest()

src.importer.glider_upload.trigger_step_function_ingest	(		file_id,
			client_id,
			file )

Definition at line 38 of file glider_upload.py.

upload_to_s3()

src.importer.glider_upload.upload_to_s3	(		file,
			client_id )

Definition at line 28 of file glider_upload.py.

Constant Documentation

client_id

src.importer.glider_upload.client_id = sys.argv[3]

Definition at line 15 of file glider_upload.py.

exchange_rates

src.importer.glider_upload.exchange_rates = sys.argv[4]

Definition at line 16 of file glider_upload.py.

file

src.importer.glider_upload.file = sys.argv[1]

Definition at line 13 of file glider_upload.py.

file_id

src.importer.glider_upload.file_id = sys.argv[2]

Definition at line 14 of file glider_upload.py.

myclient

src.importer.glider_upload.myclient = pymongo.MongoClient(os.environ.get('MONGO_CONNECTION'))

Definition at line 19 of file glider_upload.py.

mycol

src.importer.glider_upload.mycol = mydb["files"]

Definition at line 21 of file glider_upload.py.

mydb

src.importer.glider_upload.mydb = myclient["myFirstDatabase"]

Definition at line 20 of file glider_upload.py.

path

src.importer.glider_upload.path = os.path.dirname(sys.argv[0])

Definition at line 10 of file glider_upload.py.