Ouça mudanças em múltiplas fontes
Este exemplo de uso demonstra como configurar um conector de origem MongoDB Kafka para escutar eventos de alteração em várias coleções MongoDB e publicá-los em um tópico do Kafka.
Se precisar que o connector escute evento de alteração em um conjunto mais específico de reconhecimento de data center e collection, você poderá usar um pipeline. Um pipeline é uma aggregation pipeline do MongoDB composta de instruções para o reconhecimento de data center para filtrar ou transformar dados. Consulte a próxima seção para obter exemplos de como definir a configuração do connector pipeline para corresponder a vários nomes de reconhecimento de data center e collection usando uma expressão regular.
Observação
As definições de configuração database e collection também afetam os bancos de dados e as collections em que o conector escuta os eventos de alteração. Para saber mais sobre essas configurações, consulte o guia Propriedades da conexão de origem do MongoDB .
Exemplos
Os exemplos a seguir mostram como usar uma aggregation pipeline para selecionar nomes específicos de reconhecimento de data center ou de collection para escutar evento de alteração.
Incluir evento de alteração de vários reconhecimento de data center
Você pode definir um aggregation pipeline para selecionar apenas eventos de alteração em vários bancos de dados, especificando o seguinte na configuração pipeline :
Um operador de agregação
$matchO campo
ns.db, que identifica a parte do reconhecimento de data center do namespaceO operador
$regexe uma expressão regular que corresponda aos nomes do reconhecimento de data center
A configuração de exemplo a seguir mostra como definir o connector de origem para escutar evento de alteração no reconhecimento de data center sandbox e firewall :
pipeline=[{"$match": {"ns.db": {"$regex": "/^(sandbox|firewall)$/"}}}]
Excluir evento de alteração de várias collection
Você pode definir um aggregation pipeline para ignorar evento de alteração em várias collection, especificando o seguinte na configuração pipeline :
Um operador de agregação
$matchO campo
ns.coll, que identifica a parte da collection do namespaceO operador
$regexe uma expressão regular que corresponde aos nomes da collectionO operador
$notque instrui o operador$regexencerramento a corresponder a tudo o que a expressão regular não corresponde
A seguinte configuração de exemplo mostra como você pode definir seu connector de origem para filtrar evento de alteração originados de todas as collection chamadas "hiperspace" em qualquer reconhecimento de data center:
pipeline=[{"$match": {"ns.coll": {"$regex": {"$not": "/^hyperspace$/"}}}}]
Informações adicionais
Sintaxe de expressão regular utilizando a classe Padrões