This is an automated email from the ASF dual-hosted git repository.
pandaapo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new a77a2fd0e feat: Add doc for eventmesh-connector-mongodb (#4649)
a77a2fd0e is described below
commit a77a2fd0e0ea50fc9af06c3f8e6da66d69b32060
Author: Fabian Bao <[email protected]>
AuthorDate: Fri Dec 15 12:01:30 2023 +0800
feat: Add doc for eventmesh-connector-mongodb (#4649)
---
.../eventmesh-connector-mongodb/README.md | 34 ++++++++++++++++++++++
.../eventmesh-connector-mongodb/README_CN.md | 34 ++++++++++++++++++++++
.../eventmesh-connector-rabbitmq/README_CN.md | 2 +-
3 files changed, 69 insertions(+), 1 deletion(-)
diff --git a/eventmesh-connectors/eventmesh-connector-mongodb/README.md
b/eventmesh-connectors/eventmesh-connector-mongodb/README.md
new file mode 100644
index 000000000..ab388e980
--- /dev/null
+++ b/eventmesh-connectors/eventmesh-connector-mongodb/README.md
@@ -0,0 +1,34 @@
+# eventmesh-connector-mongodb
+
+## MongoDBSinkConnector: from eventmesh to mongodb.
+
+1. launch your mongodb server and eventmesh-runtime.
+2. enable sinkConnector and check `sink-config.yml`.
+3. send a message to eventmesh with the topic defined in `pubSubConfig.subject`
+```yaml
+pubSubConfig:
+ # default port is 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` and you are ready to forward message.
+4. write a cloudevent message to `yourCol` at `yourDB` in your mongodb and
then you will receive the message in eventmesh.
\ No newline at end of file
diff --git a/eventmesh-connectors/eventmesh-connector-mongodb/README_CN.md
b/eventmesh-connectors/eventmesh-connector-mongodb/README_CN.md
new file mode 100644
index 000000000..bf9e08574
--- /dev/null
+++ b/eventmesh-connectors/eventmesh-connector-mongodb/README_CN.md
@@ -0,0 +1,34 @@
+# eventmesh-connector-mongodb
+
+## MongoDBSinkConnector:从 eventmesh 到 mongodb。
+
+1. 启动你的 mongodb 服务和 eventmesh-runtime。
+2. 启用 sinkConnector 并检查 `sink-config.yml`。
+3. 向 eventmesh 发送带有在 `pubSubConfig.subject` 中定义的主题消息。
+```yaml
+pubSubConfig:
+ # 默认端口 10000
+ meshAddress: your.eventmesh.server:10000
+ subject: TopicTest
+ idc: FT
+ env: PRD
+ group: rabbitmqSink
+ appId: 5031
+ userName: rabbitmqSinkUser
+ passWord: rabbitmqPassWord
+connectorConfig:
+ connectorName: mongodbSink
+ # 支持 REPLICA_SET 和 STANDALONE
+ connectorType: STANDALONE
+ # mongodb://root:[email protected]:27018,127.0.0.1:27019
+ url: mongodb://127.0.0.1:27018
+ database: yourDB
+ collection: yourCol
+```
+
+## MongoDBSourceConnector:从 mongodb 到 eventmesh。
+
+1. 启动你的 mongodb 服务和 eventmesh-runtime。
+2. 启用 sourceConnector 并检查 `source-config.yml`(与 sink-config.yml 基本相同)。
+3. 启动你的 MongoDBSourceConnector,现在都已经准备好了。
+4. 向 mongodb 中 `yourDB` 的 `yourCol` 写入一个 cloudevent 消息,然后你将在 eventmesh 中接收到该消息。
\ No newline at end of file
diff --git a/eventmesh-connectors/eventmesh-connector-rabbitmq/README_CN.md
b/eventmesh-connectors/eventmesh-connector-rabbitmq/README_CN.md
index df9f5a3ab..00fd299f4 100644
--- a/eventmesh-connectors/eventmesh-connector-rabbitmq/README_CN.md
+++ b/eventmesh-connectors/eventmesh-connector-rabbitmq/README_CN.md
@@ -34,7 +34,7 @@ connectorConfig:
## RabbitMQSourceConnector:从 rabbitmq 到 eventmesh。
-1. 启动你的 rabbitmq 服务器和 eventmesh-runtime。
+1. 启动你的 rabbitmq 服务和 eventmesh-runtime。
2. 启用 sourceConnector 并检查 `source-config.yml`(与 sink-config.yml 基本相同)。
3. 启动你的 RabbitMQConnectorServer,你会在 rabbitmq 服务中找到该channel。
4. 向队列发送一个 cloudevent 消息,然后你将在 eventmesh 中接收到该消息。
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]