remove unsupport connector type
This commit is contained in:
parent
bd1ada0d88
commit
98e2dfcdc8
|
@ -79,7 +79,7 @@ TDengine 提供了丰富的应用程序开发接口,为了便于用户快速
|
||||||
|
|
||||||
## 安装连接器
|
## 安装连接器
|
||||||
|
|
||||||
<Tabs groupId="lang">
|
<Tabs defaultValue="java" groupId="lang">
|
||||||
<TabItem label="Java" value="java">
|
<TabItem label="Java" value="java">
|
||||||
|
|
||||||
如果使用 Maven 管理项目,只需在 pom.xml 中加入以下依赖。
|
如果使用 Maven 管理项目,只需在 pom.xml 中加入以下依赖。
|
||||||
|
@ -439,9 +439,6 @@ DSN 的详细说明和如何使用详见 [连接功能](../../reference/connecto
|
||||||
{{#include docs/examples/csharp/wsConnect/Program.cs:main}}
|
{{#include docs/examples/csharp/wsConnect/Program.cs:main}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem label="C" value="c">
|
|
||||||
<ConnC />
|
|
||||||
</TabItem>
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
|
@ -496,16 +493,6 @@ DSN 的详细说明和如何使用详见 [连接功能](../../reference/connecto
|
||||||
{{#include docs/examples/go/connect/restexample/main.go}}
|
{{#include docs/examples/go/connect/restexample/main.go}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem label="Rust" value="rust">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C#" value="csharp">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
<ConnC />
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
|
|
||||||
|
@ -585,11 +572,6 @@ let taos = pool.get()?;
|
||||||
```
|
```
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem label="C#" value="csharp">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
<ConnC />
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
|
@ -204,8 +204,6 @@ writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO
|
||||||
{{#include docs/examples/csharp/wssml/Program.cs:main}}
|
{{#include docs/examples/csharp/wssml/Program.cs:main}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem label="C" value="c">
|
|
||||||
</TabItem>
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
|
@ -249,30 +247,6 @@ writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
|
|
||||||
### REST 连接
|
|
||||||
<Tabs defaultValue="java" groupId="lang">
|
|
||||||
<TabItem label="Java" value="java">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="Python" value="python">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="Go" value="go">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="Rust" value="rust">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C#" value="csharp">
|
|
||||||
不支持
|
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
|
||||||
|
|
||||||
|
|
||||||
## 查询写入的数据
|
## 查询写入的数据
|
||||||
|
|
||||||
运行上节的样例代码,会在 power 数据库中自动建表,我们可以通过 taos shell 或者应用程序来查询数据。下面给出用 taos shell 查询超级表和 meters 表数据的样例。
|
运行上节的样例代码,会在 power 数据库中自动建表,我们可以通过 taos shell 或者应用程序来查询数据。下面给出用 taos shell 查询超级表和 meters 表数据的样例。
|
||||||
|
|
|
@ -60,9 +60,6 @@ import TabItem from "@theme/TabItem";
|
||||||
```csharp
|
```csharp
|
||||||
{{#include docs/examples/csharp/wsStmt/Program.cs:main}}
|
{{#include docs/examples/csharp/wsStmt/Program.cs:main}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
|
|
|
@ -145,10 +145,6 @@ Rust 连接器创建消费者的参数为 DSN, 可以设置的参数列表请
|
||||||
```csharp
|
```csharp
|
||||||
{{#include docs/examples/csharp/wssubscribe/Program.cs:create_consumer}}
|
{{#include docs/examples/csharp/wssubscribe/Program.cs:create_consumer}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
|
@ -160,12 +156,10 @@ Rust 连接器创建消费者的参数为 DSN, 可以设置的参数列表请
|
||||||
<Tabs groupId="lang">
|
<Tabs groupId="lang">
|
||||||
<TabItem value="java" label="Java">
|
<TabItem value="java" label="Java">
|
||||||
|
|
||||||
|
|
||||||
```java
|
```java
|
||||||
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java:create_consumer}}
|
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java:create_consumer}}
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Python" value="python">
|
<TabItem label="Python" value="python">
|
||||||
|
@ -255,16 +249,19 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
<Tabs defaultValue="java" groupId="lang">
|
<Tabs defaultValue="java" groupId="lang">
|
||||||
<TabItem value="java" label="Java">
|
<TabItem value="java" label="Java">
|
||||||
|
|
||||||
同 Websocket 代码样例。
|
```java
|
||||||
|
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:poll_data_code_piece}}
|
||||||
|
```
|
||||||
|
|
||||||
|
- `subscribe` 方法的参数含义为:订阅的主题列表(即名称),支持同时订阅多个主题。
|
||||||
|
- `poll` 每次调用获取一个消息,一个消息中可能包含多个记录。
|
||||||
|
- `ResultBean` 是我们自定义的一个内部类,其字段名和数据类型与列的名称和数据类型一一对应,这样根据 `value.deserializer` 属性对应的反序列化类可以反序列化出 `ResultBean` 类型的对象。
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
@ -282,7 +279,12 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Rust" value="rust">
|
<TabItem label="Rust" value="rust">
|
||||||
同 Websocket 示例代码
|
消费者可订阅一个或多个 `TOPIC`,一般建议一个消费者只订阅一个 `TOPIC`。
|
||||||
|
TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futures/stream/index.html) 类型,可以使用相应 API 对每个消息进行消费,并通过 `.commit` 进行已消费标记。
|
||||||
|
|
||||||
|
```rust
|
||||||
|
{{#include docs/examples/rust/restexample/examples/tmq.rs:consume}}
|
||||||
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C#" value="csharp">
|
<TabItem label="C#" value="csharp">
|
||||||
|
@ -353,18 +355,20 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
{{#include docs/examples/csharp/wssubscribe/Program.cs:seek}}
|
{{#include docs/examples/csharp/wssubscribe/Program.cs:seek}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
<Tabs groupId="lang">
|
<Tabs groupId="lang">
|
||||||
|
|
||||||
<TabItem value="java" label="Java">
|
<TabItem value="java" label="Java">
|
||||||
同 Websocket 代码样例。
|
|
||||||
|
```java
|
||||||
|
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:consumer_seek}}
|
||||||
|
```
|
||||||
|
1. 使用 consumer.poll 方法轮询数据,直到获取到数据为止。
|
||||||
|
2. 对于轮询到的第一批数据,打印第一条数据的内容,并获取当前消费者的分区分配信息。
|
||||||
|
3. 使用 consumer.seekToBeginning 方法将所有分区的偏移量重置到开始位置,并打印成功重置的消息。
|
||||||
|
4. 再次使用 consumer.poll 方法轮询数据,并打印第一条数据的内容。
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
@ -382,7 +386,17 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Rust" value="rust">
|
<TabItem label="Rust" value="rust">
|
||||||
同 Websocket 代码样例。
|
|
||||||
|
```rust
|
||||||
|
{{#include docs/examples/rust/nativeexample/examples/tmq.rs:seek_offset}}
|
||||||
|
```
|
||||||
|
|
||||||
|
1. 通过调用 consumer.assignments() 方法获取消费者当前的分区分配信息,并记录初始分配状态。
|
||||||
|
2. 遍历每个分区分配信息,对于每个分区:提取主题(topic)、消费组ID(vgroup_id)、当前偏移量(current)、起始偏移量(begin)和结束偏移量(end)。
|
||||||
|
记录这些信息。
|
||||||
|
1. 调用 consumer.offset_seek 方法将偏移量设置到起始位置。如果操作失败,记录错误信息和当前分配状态。
|
||||||
|
2. 在所有分区的偏移量调整完成后,再次获取并记录消费者的分区分配信息,以确认偏移量调整后的状态。
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C#" value="csharp">
|
<TabItem label="C#" value="csharp">
|
||||||
|
@ -446,10 +460,6 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
```csharp
|
```csharp
|
||||||
{{#include docs/examples/csharp/wssubscribe/Program.cs:commit_offset}}
|
{{#include docs/examples/csharp/wssubscribe/Program.cs:commit_offset}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
|
@ -458,7 +468,9 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
|
|
||||||
<TabItem value="java" label="Java">
|
<TabItem value="java" label="Java">
|
||||||
|
|
||||||
同 Websocket 代码样例。
|
```java
|
||||||
|
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:commit_code_piece}}
|
||||||
|
```
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
|
@ -476,7 +488,11 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Rust" value="rust">
|
<TabItem label="Rust" value="rust">
|
||||||
同 Websocket 代码样例。
|
```rust
|
||||||
|
{{#include docs/examples/rust/restexample/examples/subscribe_demo.rs:consumer_commit_manually}}
|
||||||
|
```
|
||||||
|
|
||||||
|
可以通过 `consumer.commit` 方法来手工提交消费进度。
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Node.js" value="node">
|
<TabItem label="Node.js" value="node">
|
||||||
|
@ -541,19 +557,15 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
{{#include docs/examples/csharp/wssubscribe/Program.cs:close}}
|
{{#include docs/examples/csharp/wssubscribe/Program.cs:close}}
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
<Tabs defaultValue="java" groupId="lang">
|
<Tabs defaultValue="java" groupId="lang">
|
||||||
<TabItem value="java" label="Java">
|
<TabItem value="java" label="Java">
|
||||||
|
|
||||||
同 Websocket 代码样例。
|
```java
|
||||||
|
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:unsubscribe_data_code_piece}}
|
||||||
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Python" value="python">
|
<TabItem label="Python" value="python">
|
||||||
|
@ -570,7 +582,11 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Rust" value="rust">
|
<TabItem label="Rust" value="rust">
|
||||||
同 Websocket 代码样例。
|
```rust
|
||||||
|
{{#include docs/examples/rust/restexample/examples/tmq.rs:unsubscribe}}
|
||||||
|
```
|
||||||
|
|
||||||
|
**注意**:消费者取消订阅后无法重用,如果想订阅新的 `topic`, 请重新创建消费者。
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Node.js" value="node">
|
<TabItem label="Node.js" value="node">
|
||||||
|
@ -638,10 +654,6 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
|
||||||
```
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="C" value="c">
|
|
||||||
|
|
||||||
</TabItem>
|
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
||||||
### 原生连接
|
### 原生连接
|
||||||
|
|
Loading…
Reference in New Issue