権限アクションは、データベースユーザーまたはカスタムロールがStream Processing ワークスペース内のストリームプロセッサで実行できる操作を定義します。ユーザーが必要とする権限アクションのみを、そのユーザーまたはカスタムロールに割り当てます。
すべての特権アクションは、Stream Processing ワークスペース全体に適用されます。Stream Processing ワークスペース内の個別の名前付きプロセッサーにスコープすることはできません。すべてのアクションは Atlas Stream Processing インスタンスにのみ有効です。
atlasAdmin または readWriteAnyDatabase ロールを持つユーザーは、すべての Stream Processing アクションを実行できます。readAnyDatabase ロールを持つユーザーは、読み取り専用のサブセットを実行できます。詳細については、組み込みロールの概要を参照してください。
ユーザーにアクションに必要な権限がない場合、コマンドは MongoServerError[Unauthorized]: not authorized: missing privilege for action <privilege-action> on resource <resource> を返します。
特定のAtlas Stream Processing権限アクションを持つカスタムロールを作成するには、「カスタムロールの追加」を参照してください。
組み込みロールの概要
次の表は、Atlas Stream Processing の権限アクションを含む組み込みロールを示します。
組み込みロール | 含まれる権限アクション |
|---|---|
すべての Atlas Stream Processing 権限アクション | |
| |
すべての Atlas Stream Processing 権限アクション |
Atlas Stream Processing アクション
createStreamProcessorパイプラインとオプションを含む新しい名前付きストリーム プロセッサーを定義する
sp.createStreamProcessor()メソッドを認可します。ユーザーが名前付きストリームプロセッサを開始する前に作成できるように、このアクションを割り当てます。
注意
Atlas Stream Processing は、作成時に階層形式を検証します。Atlas Stream Processing は、プロセッサーを作成するときではなく、起動するときに最大階層サイズを強制します。
dropStreamProcessor名前付きストリーム プロセッサーを永久的に削除する
sp.processor.drop()メソッドを認可します。ストリーム プロセッシング プロセッサーを削除できるように、このアクションをユーザーに割り当てます。このアクションを持つユーザーは、Stream Processing ワークスペース内のプロセッサーを削除できます。このアクションを特定の名前付きプロセッサーに制限するメカニズムはありません。
getStreamProcessor名前付きストリーム プロセッサーの状態と構成を取得する
getStreamProcessorコマンドを認可します。結果には、名前、状態、パイプライン、エラー メッセージ、最後の状態変更時間が含まれます。ユーザーが特定のストリームプロセッサーの状態を検査できるように、このアクションを割り当てます。
listStreamConnectionsStream Processing ワークスペース接続レジストリのすべての接続をリストする
sp.listConnections()メソッドを認可します。接続タイプに応じて、結果には接続名、タイプ、クラスター名、プロジェクトID、リージョン、ブートストラップサーバー、ストレージアカウントフィールドが含まれる場合があります。このアクションを割り当てると、ユーザーは Stream Processing ワークスペースで Stream Processing プロセッサーが利用できるデータソースとシンクを表示できるようになります。
listStreamProcessorsStream Processing ワークスペース内のすべてのストリーム プロセッサを一覧表示する
sp.listStreamProcessors()メソッドを認可します。結果には、名前、ID、最終更新時刻、状態、階層、エラー メッセージ、ワーカー数、パイプライン、デッドレターキュー (DLQ)、最終状態変更時刻などが含まれます。フィルターを渡して結果を絞り込むことができます。このアクションを割り当てると、ユーザーはStream Processingワークスペース内のすべてのストリームプロセッサーを検出できるようになります。ドライバーとツールでプロセッサーリストを移入するにも、このアクションが必要です。このコマンドは、Stream Processingワークスペース内のすべてのプロセッサーを返します。特定の名前付きプロセッサに対する可視性を制限するメカニズムはありません。
modifyStreamProcessor既存のストリームプロセッサーを変更する
sp.processor.modify()メソッドを認可します。このアクションを割り当てると、ユーザーはストリーム プロセッサーの構成を削除して再作成することなく更新できるようになります。
processStreamProcessor名前付きプロセッサーを作成せずに、ストリームプロセシングパイプラインをワンショットモードで実行する
processStreamProcessorコマンドを認可します。このアクションを割り当てて、ユーザーがパイプラインをワンショットモードで実行できるようにします。
注意
sp.process()mongosh メソッドを実行するには、sampleStreamProcessor権限 アクションも割り当てます。sp.process()は内部的にサンプルメカニズムを使用し、両方の権限が必要です。
sampleStreamProcessorsp.processor.sample()メソッドと基礎のとなるstartSampleStreamProcessorコマンドとgetMoreSampleStreamProcessorコマンドを認可します。startSampleStreamProcessorを使用して、名前付きの実行中のストリームプロセッサーでサンプリング セッションを開始します。getMoreSampleStreamProcessorを使用して、次のバッチの結果を取得します。batchSizeが0の場合、または省略されている場合、デフォルトのバッチする サイズは5です。このアクションを割り当てると、ユーザーは実行中のストリーム プロセッサーからのライブ出力を事前に表示したり、サンプル結果をページ分けして表示したりできます。サンプリング セッションは、プロセッサーのライブ出力に接続します。プロセッサーは実行中にのみ結果を生成します。
startStreamProcessor名前付きストリーム プロセッサーを開始または再開する
sp.processor.start()メソッドを認可します。このアクションを割り当てると、ユーザーは名前付きストリーム プロセッサーを開始または再開できるようになります。
stopStreamProcessor実行中の名前付きストリームプロセッサーを停止する
sp.processor.stop()メソッドを認可します。ユーザーが実行中のストリームプロセッサーを一時停止または停止できるように、このアクションを割り当てます。
streamProcessorStatsストリームプロセッサの操作メトリクスを検索するために
getStreamProcessorStatsコマンドを使用するsp.processor.stats()メソッドを認可します。Atlas Stream Processingでは、メトリクスが使用できない場合、統計ドキュメントは省略されます。詳細についてはverbose: trueを渡します。詳細モードには別個の権限は必要ありません。ストリームプロセッサーのスループット、エラー率、または操作メトリクスをモニターできるように、このアクションをユーザーに割り当てます。