AWSDoc AWS SDK サンプルリポジトリには、その他の SDK GitHub サンプルがあります
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
SDK を使用して Kinesis ストリームを記述する AWS
以下のコード例は、Kinesis ストリームを記述する方法を示しています。
- Python
-
- SDK for Python (Boto3)
-
注記
にはまだまだあります。 GitHub用例一覧を検索し、AWS コード例リポジトリ
での設定と実行の方法を確認してください。 class KinesisStream: """Encapsulates a Kinesis stream.""" def __init__(self, kinesis_client): """ :param kinesis_client: A Boto3 Kinesis client. """ self.kinesis_client = kinesis_client self.name = None self.details = None self.stream_exists_waiter = kinesis_client.get_waiter("stream_exists") def describe(self, name): """ Gets metadata about a stream. :param name: The name of the stream. :return: Metadata about the stream. """ try: response = self.kinesis_client.describe_stream(StreamName=name) self.name = name self.details = response["StreamDescription"] logger.info("Got stream %s.", name) except ClientError: logger.exception("Couldn't get %s.", name) raise else: return self.details
-
API の詳細については、『AWSSDK for Python (Boto3) API リファレンス』のを参照してくださいDescribeStream。
-
- Rust
-
- SDK for Rust
-
注記
これはプレビューリリースの SDK に関するドキュメントです。SDK は変更される場合があり、本稼働環境では使用しないでください。
注記
にはまだまだあります。 GitHub用例一覧を検索し、AWS コード例リポジトリ
での設定と実行の方法を確認してください。 async fn show_stream(client: &Client, stream: &str) -> Result<(), Error> { let resp = client.describe_stream().stream_name(stream).send().await?; let desc = resp.stream_description.unwrap(); println!("Stream description:"); println!(" Name: {}:", desc.stream_name()); println!(" Status: {:?}", desc.stream_status()); println!(" Open shards: {:?}", desc.shards.len()); println!(" Retention (hours): {}", desc.retention_period_hours()); println!(" Encryption: {:?}", desc.encryption_type.unwrap()); Ok(()) }
-
API の詳細については、「AWSSDK for Rust API リファレンス」のを参照してくださいDescribeStream
。
-
- SAP ABAP
-
- SDK for SAP ABAP
-
注記
にはまだまだあります GitHub。用例一覧を検索し、AWS コード例リポジトリ
での設定と実行の方法を確認してください。 TRY. oo_result = lo_kns->describestream( iv_streamname = iv_stream_name ). DATA(lt_stream_description) = oo_result->get_streamdescription( ). MESSAGE 'Streams retrieved.' TYPE 'I'. CATCH /aws1/cx_knslimitexceededex . MESSAGE 'The request processing has failed because of a limit exceed exception.' TYPE 'E'. CATCH /aws1/cx_knsresourcenotfoundex . MESSAGE 'Resource being accessed is not found.' TYPE 'E'. ENDTRY.
-
API の詳細については、AWSSDK for SAP ABAP API リファレンスのを参照してくださいDescribeStream。
-
コンシューマーの登録を解除します。
ストリームからデータをバッチで取得