upload_data function logic for Batch Uploader InfluxDB

uploader_cont.py

def upload_data(batch_data):
    if connected_to_cloud():
        try:
            if CLOUD_DB.write_points(batch_data, time_precision='ms'):
                logger.info('Write Successful to Cloud')
                
                logger.info('Updating local database with status=1 field')
                
                # for each point add `status=1` field
                for point in batch_data:
                    point['fields']['status'] = 1
                if LOCAL_DB.write_points(batch_data, write_precision='ms'):
                    logger.info('Local DB updated')
         except InfluxDBClientError as e:
            LOCAL_DB.close()
            CLOUD_DB.close()
            raise(e)