Merge pull request #16156 from taosdata/docs/test/TD-18415-update-sharp-tmq-doc
docs(driver):update nodejs tmq doc
This commit is contained in:
commit
083b9f69ea
|
@ -134,7 +134,7 @@ func (c *Consumer) Unsubscribe() error
|
||||||
|
|
||||||
<TabItem value="C#" label="C#">
|
<TabItem value="C#" label="C#">
|
||||||
|
|
||||||
```C#
|
```csharp
|
||||||
ConsumerBuilder(IEnumerable<KeyValuePair<string, string>> config)
|
ConsumerBuilder(IEnumerable<KeyValuePair<string, string>> config)
|
||||||
|
|
||||||
virtual IConsumer Build()
|
virtual IConsumer Build()
|
||||||
|
@ -158,6 +158,26 @@ void Close()
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
<TabItem label="Node.JS" value="Node.JS">
|
||||||
|
|
||||||
|
```node
|
||||||
|
function TMQConsumer(config)
|
||||||
|
|
||||||
|
function subscribe(topic)
|
||||||
|
|
||||||
|
function consume(timeout)
|
||||||
|
|
||||||
|
function subscription()
|
||||||
|
|
||||||
|
function unsubscribe()
|
||||||
|
|
||||||
|
function commit(msg)
|
||||||
|
|
||||||
|
function close()
|
||||||
|
```
|
||||||
|
|
||||||
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
## 写入数据
|
## 写入数据
|
||||||
|
@ -376,7 +396,7 @@ if err != nil {
|
||||||
|
|
||||||
<TabItem value="C#" label="C#">
|
<TabItem value="C#" label="C#">
|
||||||
|
|
||||||
```C#
|
```csharp
|
||||||
using TDengineTMQ;
|
using TDengineTMQ;
|
||||||
|
|
||||||
// 根据需要,设置消费组 (GourpId)、自动提交 (EnableAutoCommit)、
|
// 根据需要,设置消费组 (GourpId)、自动提交 (EnableAutoCommit)、
|
||||||
|
@ -400,6 +420,28 @@ var consumer = new ConsumerBuilder(cfg).Build();
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
<TabItem label="Node.JS" value="Node.JS">
|
||||||
|
|
||||||
|
``` node
|
||||||
|
// 根据需要,设置消费组 (group.id)、自动提交 (enable.auto.commit)、
|
||||||
|
// 自动提交时间间隔 (auto.commit.interval.ms)、用户名 (td.connect.user)、密码 (td.connect.pass) 等参数
|
||||||
|
|
||||||
|
let consumer = taos.consumer({
|
||||||
|
'enable.auto.commit': 'true',
|
||||||
|
'auto.commit.interval.ms','1000',
|
||||||
|
'group.id': 'tg2',
|
||||||
|
'td.connect.user': 'root',
|
||||||
|
'td.connect.pass': 'taosdata',
|
||||||
|
'auto.offset.reset','earliest',
|
||||||
|
'msg.with.table.name': 'true',
|
||||||
|
'td.connect.ip','127.0.0.1',
|
||||||
|
'td.connect.port','6030'
|
||||||
|
});
|
||||||
|
|
||||||
|
```
|
||||||
|
|
||||||
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
上述配置中包括 consumer group ID,如果多个 consumer 指定的 consumer group ID 一样,则自动形成一个 consumer group,共享消费进度。
|
上述配置中包括 consumer group ID,如果多个 consumer 指定的 consumer group ID 一样,则自动形成一个 consumer group,共享消费进度。
|
||||||
|
@ -448,7 +490,7 @@ if err != nil {
|
||||||
|
|
||||||
<TabItem value="C#" label="C#">
|
<TabItem value="C#" label="C#">
|
||||||
|
|
||||||
```C#
|
```csharp
|
||||||
// 创建订阅 topics 列表
|
// 创建订阅 topics 列表
|
||||||
List<String> topics = new List<string>();
|
List<String> topics = new List<string>();
|
||||||
topics.add("tmq_topic");
|
topics.add("tmq_topic");
|
||||||
|
@ -464,6 +506,18 @@ consumer = TaosConsumer('topic_ctb_column', group_id='vg2')
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
<TabItem label="Node.JS" value="Node.JS">
|
||||||
|
|
||||||
|
```node
|
||||||
|
// 创建订阅 topics 列表
|
||||||
|
let topics = ['topic_test']
|
||||||
|
|
||||||
|
// 启动订阅
|
||||||
|
consumer.subscribe(topics);
|
||||||
|
```
|
||||||
|
|
||||||
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
## 消费
|
## 消费
|
||||||
|
@ -523,7 +577,7 @@ for {
|
||||||
|
|
||||||
<TabItem value="C#" label="C#">
|
<TabItem value="C#" label="C#">
|
||||||
|
|
||||||
```C#
|
```csharp
|
||||||
// 消费数据
|
// 消费数据
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
|
@ -535,6 +589,21 @@ while (true)
|
||||||
```
|
```
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
<TabItem label="Node.JS" value="Node.JS">
|
||||||
|
|
||||||
|
```node
|
||||||
|
while(true){
|
||||||
|
msg = consumer.consume(200);
|
||||||
|
// process message(consumeResult)
|
||||||
|
console.log(msg.topicPartition);
|
||||||
|
console.log(msg.block);
|
||||||
|
console.log(msg.fields)
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
## 结束消费
|
## 结束消费
|
||||||
|
@ -585,7 +654,7 @@ consumer.Close()
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem value="C#" label="C#">
|
<TabItem value="C#" label="C#">
|
||||||
|
|
||||||
```C#
|
```csharp
|
||||||
// 取消订阅
|
// 取消订阅
|
||||||
consumer.Unsubscribe();
|
consumer.Unsubscribe();
|
||||||
|
|
||||||
|
@ -594,6 +663,15 @@ consumer.Close();
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
<TabItem label="Node.JS" value="Node.JS">
|
||||||
|
|
||||||
|
```node
|
||||||
|
consumer.unsubscribe();
|
||||||
|
consumer.close();
|
||||||
|
```
|
||||||
|
|
||||||
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
## 删除 *topic*
|
## 删除 *topic*
|
||||||
|
|
Loading…
Reference in New Issue