awsiot¶
- class awsiot.MqttServiceClient(mqtt_connection)¶
Bases:
object
Base class for an AWS MQTT Service Client
- Parameters:
mqtt_connection (Connection) – MQTT connection to use
- property mqtt_connection: Connection¶
MQTT connection used by this client
- class awsiot.ModeledClass¶
Bases:
object
Base for input/output classes generated from an AWS service model.
- exception awsiot.V2ServiceException(message, inner_error, modeled_error)¶
Bases:
Exception
Wrapper exception thrown by V2 service clients to indicate the failure of an operation
- exception awsiot.V2DeserializationFailure(message, inner_error, payload)¶
Bases:
Exception
An exception raised when deserialization from an MQTT message payload to a modeled type fails
- class awsiot.ServiceStreamOptions(incoming_event_listener, subscription_status_listener=None, deserialization_failure_listener=None)¶
Bases:
Generic
[T
]Configuration options for an MQTT-based service streaming operation.
- Parameters:
incoming_event_listener (Callable[[T], None]) – function object to invoke when a stream message is successfully deserialized
subscription_status_listener (Optional[Callable[[awscrt.mqtt_request_response.SubscriptionStatusEvent], None]]) – function object to invoke when the operation’s subscription status changes
deserialization_failure_listener (Optional[Callable[[V2DeserializationFailure], None]]) – function object to invoke when a publish is received on the streaming subscription that cannot be deserialized into the stream’s output type. Should never happen.