def core_connect()

in SubTemplates/IoT/Lambdas/provision_device/client/provisioning_handler.py [0:0]

• 17 lines of code
• 2 McCabe index (conditional complexity)

    def core_connect(self):
        """ Method used to connect to connect to AWS IoTCore Service. Endpoint collected from config.
        
        """
        if self.isRotation:
            self.logger.info('##### CONNECTING WITH EXISTING CERT #####')
            print('##### CONNECTING WITH EXISTING CERT #####')
            self.get_current_certs()
        else:
            self.logger.info('##### CONNECTING WITH PROVISIONING CLAIM CERT #####')
            print('##### CONNECTING WITH PROVISIONING CLAIM CERT #####')

        self.primary_MQTTClient.configureEndpoint(self.iot_endpoint, 8883)
        self.primary_MQTTClient.configureCredentials("{}/{}".format(self.secure_cert_path, 
                                                    self.root_cert), "{}/{}".format(self.secure_cert_path, self.secure_key), 
                                                    "{}/{}".format(self.secure_cert_path, self.claim_cert))
        self.primary_MQTTClient.configureOfflinePublishQueueing(-1)  
        self.primary_MQTTClient.configureDrainingFrequency(2)  
        self.primary_MQTTClient.configureConnectDisconnectTimeout(10)  
        self.primary_MQTTClient.configureMQTTOperationTimeout(3) 
        
        self.primary_MQTTClient.connect()