lab2/inference_client/sample-client-camera-mqtt.py [68:98]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                bitmap=pb2.Bitmap(
                    width=w,
                    height=h,
                    byte_data=bytes(img.tobytes())
                    ) 
                )
        )
        
        event_loop_group = io.EventLoopGroup(1)
        host_resolver = io.DefaultHostResolver(event_loop_group)
        client_bootstrap = io.ClientBootstrap(event_loop_group, host_resolver)
        mqtt_connection = mqtt_connection_builder.mtls_from_path(
                            endpoint=ENDPOINT,
                            cert_filepath=PATH_TO_CERTIFICATE,
                            pri_key_filepath=PATH_TO_PRIVATE_KEY,
                            client_bootstrap=client_bootstrap,
                            ca_filepath=PATH_TO_AMAZON_ROOT_CA_1,
                            client_id=CLIENT_ID,
                            clean_session=False,
                            keep_alive_secs=6
                            )
        print("Connecting to {} with client ID '{}'...".format(
                    ENDPOINT, CLIENT_ID))
        # Make the connect() call
        connect_future = mqtt_connection.connect()
        # Future.result() waits until a result is available
        connect_future.result()
        print("Connected!")
        # Publish message to server desired number of times.
        print('Begin Publish')
        data = "{} [{}]".format(str(response),1)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



lab2/inference_client/sample-client-file-mqtt.py [35:64]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            bitmap=pb2.Bitmap(
                width=w,
                height=h,
                byte_data=bytes(img.tobytes())
                ) 
            )
   )
   event_loop_group = io.EventLoopGroup(1)
   host_resolver = io.DefaultHostResolver(event_loop_group)
   client_bootstrap = io.ClientBootstrap(event_loop_group, host_resolver)
   mqtt_connection = mqtt_connection_builder.mtls_from_path(
                    endpoint=ENDPOINT,
                    cert_filepath=PATH_TO_CERTIFICATE,
                    pri_key_filepath=PATH_TO_PRIVATE_KEY,
                    client_bootstrap=client_bootstrap,
                    ca_filepath=PATH_TO_AMAZON_ROOT_CA_1,
                    client_id=CLIENT_ID,
                    clean_session=False,
                    keep_alive_secs=6
                    )
   print("Connecting to {} with client ID '{}'...".format(
            ENDPOINT, CLIENT_ID))
   # Make the connect() call
   connect_future = mqtt_connection.connect()
   # Future.result() waits until a result is available
   connect_future.result()
   print("Connected!")
   # Publish message to server desired number of times.
   print('Begin Publish')
   data = "{} [{}]".format(str(response),1)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -