Glider
Loading...
Searching...
No Matches
ReportSnapshot.py File Reference

Go to the source code of this file.

Namespaces

namespace  src
 
namespace  src.report_generation
 
namespace  src.report_generation.ReportSnapshot
 

Functions

 src.report_generation.ReportSnapshot.read_report_csv (filename, chunk)
 
 src.report_generation.ReportSnapshot.group_by_field (data, fields, snapshot)
 
 src.report_generation.ReportSnapshot.build_snapshot (df, field, snapshot)
 
 src.report_generation.ReportSnapshot.upload_mongo (event, final_path, snapshot, period)
 
 src.report_generation.ReportSnapshot.search_snpashots_id (files, date)
 
 src.report_generation.ReportSnapshot.create_snapshot (event, final_path)
 

Constants

 src.report_generation.ReportSnapshot.f_path = __file__
 
 src.report_generation.ReportSnapshot.index = f_path.find("report_generation/")
 
 src.report_generation.ReportSnapshot.ACCESS_ID
 Access keys for AWS.
 
 src.report_generation.ReportSnapshot.ACCESS_KEY
 Access keys for AWS.
 
 src.report_generation.ReportSnapshot.mongo_conn = mongo_connection()
 Class to connect to mongodb.
 
 src.report_generation.ReportSnapshot.snap_collection = mongo_conn.mongo_conn_snapshots()
 Mongo collection to create/update snapshots.
 
 src.report_generation.ReportSnapshot.final_df = DataFrame()
 
int src.report_generation.ReportSnapshot.total_rows = 0
 
int src.report_generation.ReportSnapshot.total_local = 0
 
 src.report_generation.ReportSnapshot.session = boto3.Session(aws_access_key_id=ACCESS_ID, aws_secret_access_key= ACCESS_KEY)
 Connection for AWS using boto3.
 
 src.report_generation.ReportSnapshot.update_at = dt.now().replace(hour=0, minute=0, second=0, microsecond=0)
 It's used to know when snapshot was created/updated.