correct writing
This commit is contained in:
parent
f6f16ac197
commit
8fdd85f1b2
|
@ -91,7 +91,7 @@ toc_max_heading_level: 4
|
||||||
|
|
||||||
5. 对于小数据量场景,私有化部署太重:在物联网、车联网场景中,因为涉及到生产经营数据的安全,很多还是采取私有化部署。而每个私有化部署,处理的数据量有很大的区别,从几百台联网设备到数千万台设备不等。对于数据量小的场景,通用的大数据解决方案就显得过于臃肿,投入产出不成正比。因此有的平台提供商往往有两套方案,一套针对大数据场景,使用通用的大数据平台,一套针对小数据规模场景,就使用 MySQL 或其他数据库来搞定一切,但是随着历史数据的累积,或接入设备量的增长,关系型数据库性能不足、运维复杂、扩展性差等缺点都会逐渐暴露出来,终究不是长久之计。
|
5. 对于小数据量场景,私有化部署太重:在物联网、车联网场景中,因为涉及到生产经营数据的安全,很多还是采取私有化部署。而每个私有化部署,处理的数据量有很大的区别,从几百台联网设备到数千万台设备不等。对于数据量小的场景,通用的大数据解决方案就显得过于臃肿,投入产出不成正比。因此有的平台提供商往往有两套方案,一套针对大数据场景,使用通用的大数据平台,一套针对小数据规模场景,就使用 MySQL 或其他数据库来搞定一切,但是随着历史数据的累积,或接入设备量的增长,关系型数据库性能不足、运维复杂、扩展性差等缺点都会逐渐暴露出来,终究不是长久之计。
|
||||||
|
|
||||||
由于存在这些根本性的缺陷,导致高速增长的时序大数据市场一直没有一个简单好用而又高效的工具。于是,近些年一批专注时序数据处理的企业杀入了这个赛道,比如美国的 InfluxData,其产品 InfluxDB 在 IT 运维监测方面有相当的市场占有率。开源社区也十分活跃,比如基于 HBase 开发的 OpenTSDB,中国国内,阿里、百度、华为都有基于 OpenTSDB 的产品,涛思数据不依赖任何第三方,推出了自主研发而且开源的的 TDengine。
|
由于存在这些根本性的缺陷,导致高速增长的时序大数据市场一直没有一个简单好用而又高效的工具。于是,近些年一批专注时序数据处理的企业杀入了这个赛道,比如美国的 InfluxData,其产品 InfluxDB 在 IT 运维监测方面有相当的市场占有率。开源社区也十分活跃,比如基于 HBase 开发的 OpenTSDB,中国国内,阿里、百度、华为都有基于 OpenTSDB 的产品,涛思数据不依赖任何第三方,推出了自主研发而且开源的 TDengine。
|
||||||
|
|
||||||
由于数据量巨大且应用方式特殊,对时序数据的处理具有相当大的技术挑战,因此要使用专业的大数据平台。对实时时序数据的科学合理地高效处理能够帮助企业实时监控生产与经营过程,对历史时序数据的分析有助于对资源的使用和生产配置做出科学的决策。
|
由于数据量巨大且应用方式特殊,对时序数据的处理具有相当大的技术挑战,因此要使用专业的大数据平台。对实时时序数据的科学合理地高效处理能够帮助企业实时监控生产与经营过程,对历史时序数据的分析有助于对资源的使用和生产配置做出科学的决策。
|
||||||
|
|
||||||
|
|
|
@ -492,7 +492,7 @@ Rust 连接器创建消费者的参数为 DSN, 可以设置的参数列表请
|
||||||
3. 对于每个分配,使用 `tmq_offset_seek` 函数将消费者的偏移量设置到最早的偏移量。
|
3. 对于每个分配,使用 `tmq_offset_seek` 函数将消费者的偏移量设置到最早的偏移量。
|
||||||
4. 如果设置偏移量失败,则打印错误信息。
|
4. 如果设置偏移量失败,则打印错误信息。
|
||||||
5. 释放分配信息数组以释放资源。
|
5. 释放分配信息数组以释放资源。
|
||||||
6. 调用 `basic_consume_loop` 函数开始新的的消费循环,处理消息。
|
6. 调用 `basic_consume_loop` 函数开始新的消费循环,处理消息。
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
<TabItem label="REST API" value="rest">
|
<TabItem label="REST API" value="rest">
|
||||||
|
|
|
@ -783,7 +783,7 @@ TDengine 的异步 API 均采用非阻塞调用模式。应用程序可以用多
|
||||||
- **返回值**:非 `NULL`:成功,返回一个 TAOS * 类型的指针,指向与 TDengine 数据库的连接句柄。`NULL`:失败,非法的输入参数。
|
- **返回值**:非 `NULL`:成功,返回一个 TAOS * 类型的指针,指向与 TDengine 数据库的连接句柄。`NULL`:失败,非法的输入参数。
|
||||||
|
|
||||||
- `const char *tmq_get_table_name(TAOS_RES *res)`
|
- `const char *tmq_get_table_name(TAOS_RES *res)`
|
||||||
- **接口说明**:从 TMQ 消费者获取的消息结果中获取所属的的表名。
|
- **接口说明**:从 TMQ 消费者获取的消息结果中获取所属的表名。
|
||||||
- res:[入参] 指向一个有效的 TAOS_RES 结构体指针,该结构体包含了从 TMQ 消费者轮询得到的消息。
|
- res:[入参] 指向一个有效的 TAOS_RES 结构体指针,该结构体包含了从 TMQ 消费者轮询得到的消息。
|
||||||
- **返回值**:非 `NULL`:成功,返回一个 const char * 类型的指针,指向表名字符串。`NULL`:失败,非法的输入参数。
|
- **返回值**:非 `NULL`:成功,返回一个 const char * 类型的指针,指向表名字符串。`NULL`:失败,非法的输入参数。
|
||||||
|
|
||||||
|
|
|
@ -307,7 +307,7 @@ TaosResult 对象可以通过循环遍历获取查询到的数据。
|
||||||
- **参数说明**:
|
- **参数说明**:
|
||||||
- `topic`: 订阅的主题。
|
- `topic`: 订阅的主题。
|
||||||
- `vg_id`: vgroupid。
|
- `vg_id`: vgroupid。
|
||||||
- `offset`:需要设置的的偏移量。
|
- `offset`:需要设置的偏移量。
|
||||||
- **异常**:操作失败抛出 ConsumerException 异常。
|
- **异常**:操作失败抛出 ConsumerException 异常。
|
||||||
- `fn committed(&mut self, topic: &str, vg_id: i32) -> PyResult<i64>`
|
- `fn committed(&mut self, topic: &str, vg_id: i32) -> PyResult<i64>`
|
||||||
- **接口说明**:获取订阅主题的vgroupid分区最后提交的偏移量。
|
- **接口说明**:获取订阅主题的vgroupid分区最后提交的偏移量。
|
||||||
|
@ -489,7 +489,7 @@ TaosResult 对象可以通过循环遍历获取查询到的数据。
|
||||||
- `def seek(self, partition)`
|
- `def seek(self, partition)`
|
||||||
- **接口说明**:将给定分区的偏移量设置到指定的位置。
|
- **接口说明**:将给定分区的偏移量设置到指定的位置。
|
||||||
- **参数说明**:
|
- **参数说明**:
|
||||||
- `partition`: 需要设置的的偏移量。
|
- `partition`: 需要设置的偏移量。
|
||||||
- `topic`: 订阅的主题
|
- `topic`: 订阅的主题
|
||||||
- `partition`: 分区
|
- `partition`: 分区
|
||||||
- `offset`: 偏移量
|
- `offset`: 偏移量
|
||||||
|
@ -497,7 +497,7 @@ TaosResult 对象可以通过循环遍历获取查询到的数据。
|
||||||
- `def committed(self, partitions)`
|
- `def committed(self, partitions)`
|
||||||
- **接口说明**:获取订阅主题的分区最后提交的偏移量。
|
- **接口说明**:获取订阅主题的分区最后提交的偏移量。
|
||||||
- **参数说明**:
|
- **参数说明**:
|
||||||
- `partition`: 需要设置的的偏移量。
|
- `partition`: 需要设置的偏移量。
|
||||||
- `topic`: 订阅的主题
|
- `topic`: 订阅的主题
|
||||||
- `partition`: 分区
|
- `partition`: 分区
|
||||||
- **返回值**:`partition`,分区最后提交的偏移量。
|
- **返回值**:`partition`,分区最后提交的偏移量。
|
||||||
|
@ -505,7 +505,7 @@ TaosResult 对象可以通过循环遍历获取查询到的数据。
|
||||||
- `def position(self, partitions)`
|
- `def position(self, partitions)`
|
||||||
- **接口说明**:获取给定分区当前的偏移量。
|
- **接口说明**:获取给定分区当前的偏移量。
|
||||||
- **参数说明**:
|
- **参数说明**:
|
||||||
- `partition`: 需要设置的的偏移量。
|
- `partition`: 需要设置的偏移量。
|
||||||
- `topic`: 订阅的主题
|
- `topic`: 订阅的主题
|
||||||
- `partition`: 分区
|
- `partition`: 分区
|
||||||
- **返回值**:`partition`,分区最后提交的偏移量。
|
- **返回值**:`partition`,分区最后提交的偏移量。
|
||||||
|
|
|
@ -8,7 +8,7 @@ import Tabs from "@theme/Tabs";
|
||||||
import TabItem from "@theme/TabItem";
|
import TabItem from "@theme/TabItem";
|
||||||
import RequestId from "./_request_id.mdx";
|
import RequestId from "./_request_id.mdx";
|
||||||
|
|
||||||
`@tdengine/websocket` 是 TDengine 的官方 Node.js 语言连接器。Node.js 开发人员可以通过它开发存取 TDengine 数据库的的应用软件。
|
`@tdengine/websocket` 是 TDengine 的官方 Node.js 语言连接器。Node.js 开发人员可以通过它开发存取 TDengine 数据库的应用软件。
|
||||||
|
|
||||||
Node.js 连接器源码托管在 [GitHub](https://github.com/taosdata/taos-connector-node/tree/main)。
|
Node.js 连接器源码托管在 [GitHub](https://github.com/taosdata/taos-connector-node/tree/main)。
|
||||||
|
|
||||||
|
@ -194,7 +194,7 @@ WSConfig 中的配置如下:
|
||||||
|
|
||||||
### 数据集
|
### 数据集
|
||||||
- `getMeta():Array<TDengineMeta> | null`
|
- `getMeta():Array<TDengineMeta> | null`
|
||||||
- **接口说明**:获取查询结果的的列的数量、类型和长度。
|
- **接口说明**:获取查询结果的列的数量、类型和长度。
|
||||||
- **返回值**:TDengineMeta 数据对象数组。
|
- **返回值**:TDengineMeta 数据对象数组。
|
||||||
```js
|
```js
|
||||||
export interface TDengineMeta {
|
export interface TDengineMeta {
|
||||||
|
|
Loading…
Reference in New Issue