def process_sqs()

in lambda-bulk-importer/main.py [0:0]


def process_sqs():
    global config
    certificate = config.get('certificate')
    policyName = config.get('policy_name')
    thingGroupName = config.get('thing_group_name')
    thingTypeName = config.get('thing_type_name')

    certificateId = process_certificate(certificate)
    
    if (certificateId is None):
        thingName = config['thing']
    else:
        thingName = get_name_from_certificate(certificateId)

    process_thing(thingName, certificateId, thingTypeName)
    process_policy(policyName, certificateId)
    process_thing_group(thingGroupName, thingName)