IoTHubModuleClient クラス
Azure IoT Hubまたは Azure IoT Edge インスタンスに接続する非同期モジュール クライアント。
IoTHubModuleClient の初期化子。
この初期化子を直接呼び出さないでください。 代わりに、'>>create_from_<<' クラス メソッドのいずれかを使用してインスタンス化します
- 継承
-
azure.iot.device.iothub.aio.async_clients.GenericIoTHubClientIoTHubModuleClientazure.iot.device.iothub.abstract_clients.AbstractIoTHubModuleClientIoTHubModuleClient
コンストラクター
IoTHubModuleClient(mqtt_pipeline, http_pipeline)
パラメーター
- mqtt_pipeline
- <xref:azure.iot.device.iothub.pipeline.MQTTPipeline>
IoTHub エンドポイントへの接続に使用されるパイプライン。
- http_pipeline
メソッド
connect |
クライアントをAzure IoT Hubまたは Azure IoT Edge Hub インスタンスに接続します。 宛先は、このオブジェクトの初期化時に指定された auth_provider パラメーターを介して渡された資格情報に基づいて選択されます。 |
create_from_connection_string |
IoTHub デバイスまたはモジュール接続文字列からクライアントをインスタンス化します。 |
create_from_edge_environment |
IoT Edge環境からクライアントをインスタンス化します。 このメソッドは、IoT Edge コンテナー内、または Edge 開発用に構成されたデバッグ環境 (Visual Studio、Visual Studio Code など) でのみ実行できます。 |
create_from_sastoken |
事前に作成された SAS トークン文字列からクライアントをインスタンス化する |
create_from_x509_certificate |
X509 証明書認証を使用してクライアントをインスタンス化します。 |
disconnect |
Azure IoT Hubまたは Azure IoT Edge Hub インスタンスからクライアントを切断します。 クライアント インスタンスが完全に完了したら、このコルーチンを必ず呼び出すようにすることをお勧めします。 |
get_twin |
Azure IoT Hubまたは Azure IoT Edge Hub サービスからデバイスまたはモジュール ツインを取得します。 |
invoke_method |
クライアントからデバイスまたはモジュール クライアントにメソッドを呼び出し、メソッド呼び出しへの応答を受け取ります。 |
patch_twin_reported_properties |
報告されたプロパティを Azure IoT Hub または Azure IoT Edge Hub サービスで更新します。 サービスがパッチ操作でエラーを返した場合、この関数は適切なエラーを発生させます。 |
receive_message_on_input |
別のモジュールから特定の入力に送信された入力メッセージを受信します。 使用可能なメッセージがまだない場合は、アイテムが使用可能になるまで待機します。 バージョン 2.3.0 以降非推奨: 代わりに .on_message_received プロパティを使用してハンドラーを設定することをお勧めします |
receive_method_request |
Azure IoT Hubまたは Azure IoT Edge Hub 経由でメソッド要求を受信します。 使用可能なメソッド要求がない場合は、使用可能になるまで待機します。 バージョン 2.3.0 以降非推奨: 代わりに .on_method_request_received プロパティを使用してハンドラーを設定することをお勧めします |
receive_twin_desired_properties_patch |
Azure IoT Hubまたは Azure IoT Edge Hub 経由で目的のプロパティパッチを受け取ります。 使用可能なメソッド要求がない場合は、使用可能になるまで待機します。 バージョン 2.3.0 以降非推奨: 代わりに .on_twin_desired_properties_patch_received プロパティを使用してハンドラーを設定することをお勧めします |
send_message |
Azure IoT Hubまたは Azure IoT Edge Hub インスタンスの既定のイベント エンドポイントにメッセージを送信します。 接続の呼び出しによってサービスへの接続が以前に開かなかった場合、この関数はイベントを送信する前に接続を開きます。 |
send_message_to_output |
特定のモジュール出力にイベント/メッセージを送信します。 これらは送信イベントであり、"出力イベント" であることを意図しています 接続する呼び出しによってサービスへの接続が以前に開かっていない場合、この関数はイベントを送信する前に接続を開きます。 |
send_method_response |
Azure IoT Hubまたは Azure IoT Edge Hub 経由でメソッド要求に応答を送信します。 接続する呼び出しによってサービスへの接続が以前に開かっていない場合、この関数はイベントを送信する前に接続を開きます。 |
shutdown |
正常終了のためにクライアントをシャットダウンします。 このメソッドが呼び出されると、以降のクライアント呼び出しで試行されると、ClientError が発生します |
update_sastoken |
認証に使用するクライアントの SAS トークンを更新し、接続を再認証します。 この API は、クライアントが最初に SAS トークンを使用して作成された場合にのみ使用できます。 |
connect
クライアントをAzure IoT Hubまたは Azure IoT Edge Hub インスタンスに接続します。
宛先は、このオブジェクトの初期化時に指定された auth_provider パラメーターを介して渡された資格情報に基づいて選択されます。
async connect()
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続がタイムアウトした場合は 。
実行中に予期しないエラーが発生した場合は 。
create_from_connection_string
IoTHub デバイスまたはモジュール接続文字列からクライアントをインスタンス化します。
create_from_connection_string(connection_string, **kwargs)
パラメーター
- server_verification_cert
- str
構成オプション。 信頼された証明書チェーン。 プロトコル ゲートウェイなど、信頼の標準以外のルートを持つエンドポイントへの接続を使用する場合に必要です。
構成オプション。 TLS/SSL の暗号スイート。"OpenSSL 暗号リスト形式" の文字列、または暗号スイート文字列の一覧として使用します。
- keep_alive
- int
ブローカーとの通信間の最大期間 (秒単位)。 他のメッセージが交換されていない場合は、クライアントが ping メッセージをブローカーに送信する速度が制御されます。 指定しない場合は、既定値の 60 秒が使用されます。
戻り値
認証に接続文字列を使用する IoTHub クライアントのインスタンス。
例外
create_from_edge_environment
IoT Edge環境からクライアントをインスタンス化します。
このメソッドは、IoT Edge コンテナー内、または Edge 開発用に構成されたデバッグ環境 (Visual Studio、Visual Studio Code など) でのみ実行できます。
create_from_edge_environment(**kwargs)
パラメーター
構成オプション。 TLS/SSL の暗号スイート。"OpenSSL 暗号リスト形式" の文字列、または暗号スイート文字列の一覧として使用します。
- keep_alive
- int
ブローカーとの通信間の最大期間 (秒単位)。 他のメッセージが交換されていない場合は、クライアントが ping メッセージをブローカーに送信する速度が制御されます。 指定しない場合は、既定値の 60 秒が使用されます。
戻り値
認証にIoT Edge環境を使用する IoTHub クライアントのインスタンス。
例外
create_from_sastoken
事前に作成された SAS トークン文字列からクライアントをインスタンス化する
create_from_sastoken(sastoken, **kwargs)
パラメーター
- server_verification_cert
- str
構成オプション。 信頼された証明書チェーン。 プロトコル ゲートウェイなど、信頼の標準以外のルートを持つエンドポイントへの接続を使用する場合に必要です。
構成オプション。 TLS/SSL の暗号スイート。"OpenSSL 暗号リスト形式" の文字列、または暗号スイート文字列の一覧として使用します。
- keep_alive
- int
ブローカーとの通信間の最大期間 (秒単位)。 他のメッセージが交換されていない場合は、クライアントが ping メッセージをブローカーに送信する速度が制御されます。 指定しない場合は、既定値の 60 秒が使用されます。
例外
create_from_x509_certificate
X509 証明書認証を使用してクライアントをインスタンス化します。
create_from_x509_certificate(x509, hostname, device_id, module_id, **kwargs)
パラメーター
- x509
- X509
完全な x509 証明書オブジェクト。 証明書を使用するには、登録オブジェクトに証明書 (ルート証明書または中間 CA 証明書のいずれか) が含まれている必要があります。 証明書が CER ファイルから取得される場合は、base64 でエンコードする必要があります。
- server_verification_cert
- str
構成オプション。 信頼された証明書チェーン。 プロトコル ゲートウェイなど、信頼の標準以外のルートを持つエンドポイントへの接続を使用する場合に必要です。
構成オプション。 TLS/SSL の暗号スイート。"OpenSSL 暗号リスト形式" の文字列、または暗号スイート文字列の一覧として使用します。
- keep_alive
- int
ブローカーとの通信間の最大期間 (秒単位)。 他のメッセージが交換されていない場合は、クライアントが ping メッセージをブローカーに送信する速度が制御されます。 指定しない場合は、既定値の 60 秒が使用されます。
戻り値
認証に X509 証明書を使用する IoTHub クライアントのインスタンス。
例外
disconnect
Azure IoT Hubまたは Azure IoT Edge Hub インスタンスからクライアントを切断します。
クライアント インスタンスが完全に完了したら、このコルーチンを必ず呼び出すようにすることをお勧めします。
async disconnect()
例外
実行中に予期しないエラーが発生した場合は 。
get_twin
Azure IoT Hubまたは Azure IoT Edge Hub サービスからデバイスまたはモジュール ツインを取得します。
async get_twin()
戻り値
JSON ディクテーションとしての完全なツイン
の戻り値の型 :
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続試行がタイムアウトした場合
クライアントが接続されていない (自動接続が有効になっていない) 場合
実行中に予期しないエラーが発生した場合は 。
invoke_method
クライアントからデバイスまたはモジュール クライアントにメソッドを呼び出し、メソッド呼び出しへの応答を受け取ります。
async invoke_method(method_params, device_id, module_id=None)
パラメーター
- method_params
- dict
methodName (str)、ペイロード (str)、connectTimeoutInSeconds (int)、responseTimeoutInSeconds (int) を含める必要があります。
戻り値
method_resultには、状態とペイロードが含まれている必要があります
の戻り値の型 :
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続がタイムアウトした場合は 。
実行中に予期しないエラーが発生した場合は 。
patch_twin_reported_properties
報告されたプロパティを Azure IoT Hub または Azure IoT Edge Hub サービスで更新します。
サービスがパッチ操作でエラーを返した場合、この関数は適切なエラーを発生させます。
async patch_twin_reported_properties(reported_properties_patch)
パラメーター
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続試行がタイムアウトした場合
クライアントが接続されていない (自動接続が有効になっていない) 場合
実行中に予期しないエラーが発生した場合は 。
receive_message_on_input
別のモジュールから特定の入力に送信された入力メッセージを受信します。
使用可能なメッセージがまだない場合は、アイテムが使用可能になるまで待機します。
バージョン 2.3.0 以降非推奨: 代わりに .on_message_received プロパティを使用してハンドラーを設定することをお勧めします
receive_message_on_input(input_name)
パラメーター
戻り値
指定した入力に送信されたメッセージ。
の戻り値の型 :
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続がタイムアウトした場合は 。
実行中に予期しないエラーが発生した場合は 。
receive_method_request
Azure IoT Hubまたは Azure IoT Edge Hub 経由でメソッド要求を受信します。
使用可能なメソッド要求がない場合は、使用可能になるまで待機します。
バージョン 2.3.0 以降非推奨: 代わりに .on_method_request_received プロパティを使用してハンドラーを設定することをお勧めします
receive_method_request(method_name=None)
パラメーター
- method_name
- str
必要に応じて、要求を受信するメソッドの名前を指定します。 このパラメーターが指定されていない場合、receive_methodへの別の呼び出しによってまだ対象とされていないすべてのメソッドが受信されます。
戻り値
受信したメソッド要求を表す MethodRequest オブジェクト。
の戻り値の型 :
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続がタイムアウトした場合は 。
実行中に予期しないエラーが発生した場合は 。
receive_twin_desired_properties_patch
Azure IoT Hubまたは Azure IoT Edge Hub 経由で目的のプロパティパッチを受け取ります。
使用可能なメソッド要求がない場合は、使用可能になるまで待機します。
バージョン 2.3.0 以降非推奨: 代わりに .on_twin_desired_properties_patch_received プロパティを使用してハンドラーを設定することをお勧めします
receive_twin_desired_properties_patch()
戻り値
JSON dict としての Twin Desired Properties パッチ
の戻り値の型 :
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続がタイムアウトした場合は 。
実行中に予期しないエラーが発生した場合は 。
send_message
Azure IoT Hubまたは Azure IoT Edge Hub インスタンスの既定のイベント エンドポイントにメッセージを送信します。
接続の呼び出しによってサービスへの接続が以前に開かなかった場合、この関数はイベントを送信する前に接続を開きます。
async send_message(message)
パラメーター
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続試行がタイムアウトした場合
クライアントが接続されていない (自動接続が有効になっていない) 場合
実行中に予期しないエラーが発生した場合は 。
send_message_to_output
特定のモジュール出力にイベント/メッセージを送信します。
これらは送信イベントであり、"出力イベント" であることを意図しています
接続する呼び出しによってサービスへの接続が以前に開かっていない場合、この関数はイベントを送信する前に接続を開きます。
async send_message_to_output(message, output_name)
パラメーター
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続試行がタイムアウトした場合
クライアントが接続されていない (自動接続が有効になっていない) 場合
実行中に予期しないエラーが発生した場合は 。
send_method_response
Azure IoT Hubまたは Azure IoT Edge Hub 経由でメソッド要求に応答を送信します。
接続する呼び出しによってサービスへの接続が以前に開かっていない場合、この関数はイベントを送信する前に接続を開きます。
async send_method_response(method_response)
パラメーター
例外
資格情報が無効で、接続を確立できない場合は 。
接続を確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
接続試行がタイムアウトした場合
クライアントが接続されていない場合 (自動接続が有効になっていません)
実行中に予期しないエラーが発生した場合は 。
shutdown
正常終了のためにクライアントをシャットダウンします。
このメソッドが呼び出されると、以降のクライアント呼び出しで試行されると、ClientError が発生します
async shutdown()
例外
実行中に予期しないエラーが発生した場合は 。
update_sastoken
認証に使用するクライアントの SAS トークンを更新し、接続を再認証します。
この API は、クライアントが最初に SAS トークンを使用して作成された場合にのみ使用できます。
async update_sastoken(sastoken)
パラメーター
例外
資格情報が無効で、接続を再確立できない場合は 。
接続を再確立するとエラーが発生する場合は 。
実行中に接続が失われた場合は 。
再認証の試行がタイムアウトした場合は 。
クライアントが最初に SAS トークンを使用して作成されなかった場合は 。
実行中に予期しないエラーが発生した場合は 。
属性
connected
トランスポートが接続されているかどうかを示す読み取り専用プロパティ。
on_background_exception
バックグラウンド例外が発生すると、ハンドラー関数またはコルーチンが呼び出されます。
関数またはコルーチン定義は、1 つの位置引数 (例外オブジェクト) を受け取る必要があります
on_connection_state_change
接続状態が変更されたときに呼び出されるハンドラー関数またはコルーチン。
関数またはコルーチン定義は、位置引数を受け取らてはいけません。
on_message_received
入力メッセージの受信時に呼び出されるハンドラー関数またはコルーチン。
関数定義またはコルーチンは、1 つの位置引数 (オブジェクト) を Message 受け取る必要があります
on_method_request_received
メソッド要求の受信時に呼び出されるハンドラー関数またはコルーチン。
クライアントの .send_method_response() メソッドを使用して、関数またはコルーチンのメソッド要求を確認してください。
関数またはコルーチン定義は、1 つの位置引数 (オブジェクト) を MethodRequest 受け取る必要があります
on_new_sastoken_required
クライアントが新しい SAS トークンを必要とする場合に呼び出されるハンドラー関数またはコルーチン。 これは、SAS トークンの有効期限が切れる約 2 分前に発生します。 Windows プラットフォームでは、有効期間が約 49 日を超える場合、SAS の有効期間に関係なく、その 49 日後に新しいトークンが必要になります。
このハンドラーは、.create_from_sastoken() メソッドを使用して作成されたクライアントを使用する場合にのみ必要であることに注意してください。
新しいトークンは、クライアントの .update_sastoken() メソッドを使用して、関数またはコルーチンで提供できます。
関数またはコルーチン定義は、位置引数を受け取らてはいけません。
on_twin_desired_properties_patch_received
ツインの必要なプロパティパッチを受け取ったときに呼び出されるハンドラー関数またはコルーチン。
関数またはコルーチン定義は、1 つの位置引数を受け取る必要があります (JSON ディクショナリ オブジェクトの形式のツインパッチ)
Azure SDK for Python