IdentifyFormat.py File Reference

Go to the source code of this file.

Namespaces
namespace	src
namespace	src.importer
namespace	src.importer.IdentifyFormat

Functions
	src.importer.IdentifyFormat.download_obj (event, file)
	src.importer.IdentifyFormat.csvHeaders (event, file)
	src.importer.IdentifyFormat.identifyHeaders (headers, collection)
	src.importer.IdentifyFormat.type_schema (schema)
	src.importer.IdentifyFormat.cols_otto (schema, ottoMapping)
	src.importer.IdentifyFormat.identify_format (event, context=None)

Constants
	src.importer.IdentifyFormat.s3_file_obj = None
	It will contain the file content downloaded from s3.
	src.importer.IdentifyFormat.ENV = os.environ.get("ENVIRONMENT")
	Environment where code is running (Development/Production)
	src.importer.IdentifyFormat.ACCESS_ID
	Access keys for AWS.
	src.importer.IdentifyFormat.ACCESS_KEY
	Access keys for AWS.
	src.importer.IdentifyFormat.mongo_conn = mongo_connection()
	Class to connect to mongodb.
	src.importer.IdentifyFormat.collection = mongo_conn.mongo_conn_formats()
	Mongo collection to search formats.
	src.importer.IdentifyFormat.snap_collection = mongo_conn.mongo_conn_snapshots()
	Mongo collection to upload snapshots.
	src.importer.IdentifyFormat.s3_client = boto3.client("s3", aws_access_key_id=ACCESS_ID, aws_secret_access_key= ACCESS_KEY)
	Connection for AWS using boto3.