Docs Menu
Docs Home
/
MongoDB Atlas
/
MongoDB Atlas Kubernetes 演算子

Atlas Stream Processing の管理

Atlas Kubernetes Operator を使用して、Atlas Stream Processing のストリーム プロセシング インスタンスと接続を管理できます。 Atlas Stream Processing を使用すると、Atlas データベースで使用されるのと同じ MongoDB Query APIを使用して、複雑なデータのストリームを処理できます。 Atlas Stream Processing を使用すると、次のタスクを実行できます。

Atlas Stream Processing コンポーネントは Atlas プロジェクトに直接属し、Atlas クラスターとは独立して動作します。詳しくは、「 atlas-sp とは何ですか 」を参照してください。

Atlas Stream Processing インスタンスと接続

Atlas Stream Processing インスタンスは、ストリーミングデータに対するすべての操作のコンテキストを提供します。サンプル接続、Atlas変更ストリームへの接続、またはApache Kafkaシステムへの接続を構成できます。次に、Stream Processingインスタンスの接続レジストリに接続を追加できます。 詳しくは、Atlas Stream Processing インスタンスの管理 を参照してください。

前提条件

Atlas Kubernetes Operator を使用してストリーム処理インスタンスと接続を管理するには、次の手順を実行する必要があります。

手順

Atlas Kubernetes Operator を使用してストリームプロセシングインスタンスとその接続を管理するには、次の手順を実行します。

1

AtlasStreamInstance カスタムリソースを設定します。

例:

cat <<EOF | kubectl apply -f -
apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamInstance
metadata:
  name: my-stream-instance
spec:
  name: my-stream-instance
  clusterConfig:
    provider: AWS
    region: VIRGINIA_USA
    tier: SP30
  projectRef:
    name: my-project
EOF

利用可能なパラメータの詳細については、 AtlasStreamInstanceカスタム リソースを参照してください。

注意

現在、Atlas Kubernetes Operator は、このカスタム リソースのAWSプロバイダーとVIRGINIA_USAリージョンのみをサポートしています。

2

AtlasStreamConnection カスタムリソースを設定します。

サンプル接続、Atlas変更ストリームへの接続、またはApache Kafkaシステムへの接続を構成できます。

例:

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: sample_stream_solar
  type: Sample

注意

spec.typeパラメータにSampleを指定する場合、 spec.nameパラメータはサンプル コレクション名と一致する必要があります。 現在、Atlas Kubernetes Operator は、このカスタム リソースのsample_stream_solarサンプル コレクションのみをサポートしています。

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: my-stream-connection
  type: Cluster
  clusterConfig:
    name: my-cluster
  role:
    name: my-db-role
    type: CUSTOM
apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: my-stream-connection
  type: Kafka
  kafkaConfig:
    bootstrapServers: "comma,separated,list,of,server,addresses"
    authentication:
      mechanism: SCRAM-512
      credentials:
        name: ref-to-creds-secret
        namespace: default
    security:
      protocol: SSL
      certificate:
        name: ref-to-certificate-secret
        namespace: default

利用可能なパラメータの詳細については、 AtlasStreamConnectionカスタム リソースを参照してください。

3

カスタム リソースAtlasStreamInstance の接続レジストリに接続を追加します。

例:

cat <<EOF | kubectl apply -f -
apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamInstance
metadata:
   name: my-stream-instance
spec:
  name: my-stream-instance
  clusterConfig:
    provider: AWS
    region: VIRGINIA_USA
    tier: SP30
  projectRef:
    name: my-project
  connectionRegistry:
    - name: ref-my-connection-1
      namespace: my-namespace1
    - name: ref-my-connection-2
      namespace: my-namespace2
    - name: ref-my-connection-3
      namespace: my-namespace1
EOF

注意

現在、Atlas Kubernetes Operator は、このカスタム リソースのAWSプロバイダーとVIRGINIA_USAリージョンのみをサポートしています。

利用可能なパラメータの詳細については、 AtlasStreamInstanceカスタム リソースを参照してください。

戻る

Atlas Vector Search

次へ

Atlas クラスターのバックアップ

項目一覧