Skip to content

Latest commit

 

History

History

eventmesh-connector-mongodb

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
src/main
src/main
 
 
README.md
README.md
 
 
README_CN.md
README_CN.md
 
 
build.gradle
build.gradle
 
 
gradle.properties
gradle.properties
 
 

README.md

MongoDB

MongoDBSinkConnector: From EventMesh to MongoDB

  1. launch your MongoDB server and EventMesh Runtime.
  2. enable sinkConnector and check sink-config.yml.
  3. start your MongoDBConnectorServer, it will subscribe to the topic defined in pubSubConfig.subject of EventMesh Runtime and send data to connectorConfig.collection in your MongoDB.
  4. send a message to EventMesh with the topic defined in pubSubConfig.subject and then you will receive the message in MongoDB.
pubSubConfig:
  # default port 10000
  meshAddress: your.eventmesh.server:10000
  subject: TopicTest
  idc: FT
  env: PRD
  group: mongodbSink
  appId: 5031
  userName: mongodbSinkUser
  passWord: mongodbPassWord
connectorConfig:
  connectorName: mongodbSink
  # REPLICA_SET or STANDALONE is supported
  connectorType: STANDALONE
  # mongodb://root:[email protected]:27018,127.0.0.1:27019
  url: mongodb://127.0.0.1:27018
  database: yourDB
  collection: yourCol

MongoDBSourceConnector: From MongoDB to EventMesh

  1. launch your MongoDB server and EventMesh Runtime.
  2. enable sourceConnector and check source-config.yml (Basically the same as sink-config.yml)
  3. start your MongoDBSourceConnector, it will subscribe to the collection defined in connectorConfig.collection in your MongoDB and send data to pubSubConfig.subject of EventMesh Runtime.
  4. write a CloudEvent message to yourCol at yourDB in your MongoDB and then you will receive the message in EventMesh.