in src/jobs_configure.py [0:0]
def default_section_parser(config):
defaultConfig = {
'thingListFilePath': config['DEFAULT']['thingList'],
'binName': config['DEFAULT']['binName'],
'roleArn': config['DEFAULT']['roleArn'],
'jobId': config['DEFAULT']['jobId'],
'rounds': int(config['DEFAULT']['rounds']),
'bucket': config['DEFAULT']['bucket'],
'cleanUpCfg': config['DEFAULT'].getboolean('cleanUpCfg'),
'debug': config['DEFAULT'].getboolean('debug'),
'defaultDelay': int(config['DEFAULT']['defaultDelay']),
'useCustomJobDocument': config['DEFAULT'].getboolean('useCustomJobDocument'),
'region': config['DEFAULT']['region'],
'fileChunkSize': int(config['DEFAULT']['fileChunkSize']),
'targetSelection': config['DEFAULT']['targetSelection'],
'deviceCount': int(config['DEFAULT']['deviceCount'])
}
binName = defaultConfig['binName']
fileChunkSize = defaultConfig['fileChunkSize']
thingListFilePath = defaultConfig['thingListFilePath']
fileChunkSize = defaultConfig['fileChunkSize']
bucket = defaultConfig['bucket']
seed(1)
fileId = randint(1, 255)
defaultConfig['streamId'] = config['DEFAULT']['streamId'] + '_' + str(fileId)
defaultConfig['binFileKey'] = 'firmware/' + time.strftime("%Y%m%d-%H%M%S") + binName
binFileKey = defaultConfig['binFileKey']
status = False
file_stats = os.stat(binName)
defaultConfig['md5sum'] = md5_check_sum(binName, fileChunkSize)
thingArnList, isThingListEmpty, thingNameList = parse_thingList(thingListFilePath)
if isThingListEmpty:
raise Exception('thing list should not be empty')
s3_interface.upload_file_to_s3(binName, bucket, binFileKey)
defaultConfig['thingArnList'] = thingArnList
defaultConfig['thingNameList'] = thingNameList
defaultConfig['fileId'] = fileId
defaultConfig['fileSize'] = file_stats.st_size
return defaultConfig