メッセージの消費
この情報では、メッセージの消費について説明します。
ストリームからのメッセージを消費するには、次を行う必要があります:
- カーソルを作成する。
- そのカーソルを使用してメッセージを読み取る
- 返されたカーソルを使用してメッセージの読取りを続行する。
1つ以上のストリームから個々のコンシューマを使用してメッセージを読み取ることや、ストリームからコンシューマ・グループを使用してメッセージを読み取ることができます。
Oracle Cloud Infrastructure Connector Hubを使用して、ストリームからデータを消費したり、オブジェクト・ストレージまたはサポートされている他のコネクタ・ハブ・ターゲットにメッセージを渡したりすることもできます。
コンソールを使用してストリームの最新のメッセージを表示できますが、カーソルを管理してストリームから消費するには、CLI、APIまたはSDKを使用する必要があります。
Oracle Cloud Infrastructure (OCI) SDKを使用してメッセージを消費するには、ストリーミングの開発者ガイドを参照してください。
ストリーミングのKafka互換性を利用する場合は、Kafkaおよびストリーミングの開発を参照してください。
Oracle Cloud Infrastructure Connector Hubを使用して、ストリームからデータを消費したり、オブジェクト・ストレージまたはサポートされている他のコネクタ・ハブ・ターゲットにメッセージを渡したりすることもできます。
必要なIAMポリシー
Oracle Cloud Infrastructureを使用するには、管理者によってポリシーでセキュリティ・アクセス権が付与されている必要があります。このアクセス権は、コンソール、あるいはSDK、CLIまたはその他のツールを使用したREST APIのいずれを使用している場合でも必要です。権限がない、または認可されていないというメッセージが表示される場合は、管理者に連絡して、どのタイプのアクセス権があり、どのコンパートメントで作業するかを確認してください。
管理者の場合: ストリーミング管理者によるストリーミング・リソースの管理のポリシーにより、指定したグループは、ストリーミングおよび関連するストリーミング・サービス・リソースに対してすべてのことを実行できます。
別のテナント内のストリームからデータを消費するために、テナントにstream-pullアクセス権を付与するポリシーを作成できます。ストリーミング・サービス用のポリシーの作成についてさらに詳しく調べる場合は、テナンシをまたがったストリーミング・リソースへのアクセスおよびストリーミング・サービスの詳細を参照してください。