Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Menu Docs

AtlasStreamConnection Recurso personalizado

O AtlasStreamConnection recurso personalizado configura as conexões do Atlas Stream Processing . Você pode configurar uma conexão de amostra, uma conexão com um change stream do Atlas ou uma conexão com um sistema Apache Kafka.

Os exemplos a seguir adicionam uma conexão ao Registro de conexões do espaço de trabalho de stream processing. Para saber mais, veja Gerenciar Atlas Stream Processing.

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

Observação

Se você especificar Sample para o parâmetro spec.type , o parâmetro spec.name deverá corresponder ao nome da collection de amostra. Atualmente, o Atlas Kubernetes Operator suporta somente a collection de amostra sample_stream_solar para este recurso personalizado.

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 é o esquema para a API atlasstreamconnections

Name
Tipo
Descrição
Obrigatório

apiVersion

string

atlas.mongodb.com/v1

true

kind

string

AtlasStreamConnection

true

metadata

objeto

Consulte a documentação do Kubernetes API para os campos do campo metadata.

true

spec

objeto

AtlasStreamConnectionSpec define o estado alvo de AtlasStreamConnection.

false

status

objeto

AtlasStreamConnectionStatus define o estado observado de AtlasStreamConnection.

false

AtlasStreamConnectionSpec define o estado de destino do AtlasStreamConnection.

Name
Tipo
Descrição
Obrigatório

name

string

Etiqueta legível por humanos que identifica exclusivamente a conexão do stream.

true

type

enum

Tipo de conexão. Pode ser cluster ou Kafka. enumeração: Kafka, cluster, amostra

true

clusterConfig

objeto

A configuração a ser utilizada para conectar a um Atlas cluster.

false

kafkaConfig

objeto

A configuração a ser usada para se conectar a um Kafka Cluster.

false

A configuração a ser utilizada para conectar a um Atlas cluster.

Name
Tipo
Descrição
Obrigatório

name

string

Nome do cluster configurado para esta conexão.

true

role

objeto

O nome de uma função DB integrada ou personalizada para conectar-se a um cluster do Atlas.

true

O nome de uma função de banco de dados integrado ou personalizado para conectar-se a um cluster Atlas.

Name
Tipo
Descrição
Obrigatório

name

string

O name da função a ser usada. Pode ser uma função integrada ou uma função personalizada.

true

type

enum

Tipo da função DB. Pode ser BUILT_IN ou CUSTOM. enumeração: BUILT_IN, CUSTOM

true

A configuração a ser usada para se conectar a um Kafka Cluster.

Name
Tipo
Descrição
Obrigatório

authentication

objeto

Credenciais de usuário necessárias para se conectar a um Kafka Cluster. Inclui o tipo authentication, bem como os parâmetros para este modo authentication.

true

bootstrapServers

string

Lista separada por vírgula de endereços de servidor

true

security

objeto

Propriedades para a conexão de transporte segura com o Kafka. Para SSL, isso pode incluir o certificado confiável a ser usado.

true

config

map[string]string

Um mapa de pares de valores-chave Kafka para configuração opcional. Este é um objeto plano e as chaves podem ter '.' caracteres.

false

Credenciais de usuário necessárias para se conectar a um Kafka Cluster. Inclui o tipo de autenticação, bem como os parâmetros para esse modo de autenticação.

Name
Tipo
Descrição
Obrigatório

credentials

objeto

Referência ao segredo que contém o nome de usuário e a senha da conta para se conectar ao Kafka cluster.

true

mechanism

enum

Estilo de autenticação. Pode ser um dos PLAIN, SCRAM-256 ou SCRAM-512. enumeração: PLAIN, SCRAM-256, SCRAM-512

true

Referência ao segredo que contém o nome de usuário e a senha da conta para se conectar ao Kafka cluster.

Name
Tipo
Descrição
Obrigatório

name

string

Nome do Recurso Kubernetes

true

namespace

string

Namespace do Recurso Kubernetes

false

Propriedades para a conexão de transporte segura com o Kafka. Para SSL, isso pode incluir o certificado confiável a ser usado.

Name
Tipo
Descrição
Obrigatório

protocol

enum

Descreve o tipo de transporte. Pode ser PLAINTEXT ou SSL. enumeração: PLAINTEXT, SSL

true

certificate

objeto

Um x509 certificate público e confiável para se conectar ao Kafka por SSL.

false

Um certificado x509 público e confiável para conexão com o Kafka por SSL.

Name
Tipo
Descrição
Obrigatório

name

string

Nome do Recurso Kubernetes

true

namespace

string

Namespace do Recurso Kubernetes

false

AtlasStreamConnectionStatus define o estado observado de AtlasStreamConnection.

Name
Tipo
Descrição
Obrigatório

conditions

[] objeto

Condições é a lista de status que mostra o estado atual do Recurso Personalizado do Atlas

true

instances

[] objeto

Lista de instances usando a configuração de conexão

false

observedGeneration

inteiro

ObservedGeneration indica a geração da especificação de recurso da qual o Operador Atlas está ciente. O Operador do Atlas atualiza este campo para o valor de 'metadados.generation' assim que iniciar a reconciliação do recurso. Formato: int64

false

A condição descreve o estado de um recurso personalizado do Atlas em um determinado ponto.

Name
Tipo
Descrição
Obrigatório

status

string

Status da condição; um de verdadeiro, falso, desconhecido.

true

type

string

Tipo de condição do Atlas recurso.

true

lastTransitionTime

string

Última vez que a condição fez a transição de um status para outro. Representado no formato ISO 8601. Formato: data/hora

false

message

string

Um message fornecendo detalhes sobre a transição.

false

reason

string

O reason para a última transição da condição.

false

ResourceRefNamespaced é uma referência a um Recurso do Kubernetes que permite configurar o namespace

Name
Tipo
Descrição
Obrigatório

name

string

Nome do Recurso Kubernetes

true

namespace

string

Namespace do Recurso Kubernetes

false