更新时间:2022-02-22 GMT+08:00

创建表关联OpenTSDB

功能描述

MRS的Spark实现了访问OpenTSDB的Datasource,能够在Spark中创建关联表,查询和插入OpenTSDB数据。

使用CREATE TABLE命令创建表并关联OpenTSDB上已有的metric。

若OpenTSDB上不存在metric,查询对应的表会报错。

语法格式

CREATE TABLE [IF NOT EXISTS] OPENTSDB_TABLE_NAME   USING OPENTSDB OPTIONS (
'metric' = 'METRIC_NAME',
'tags' = 'TAG1,TAG2'
);

关键字

参数

描述

metric

所创建的表对应的OpenTSDB中的指标名称。

tags

metric对应的标签,用于归类、过滤、快速检索等操作。可以是1个到8个,以“,”分隔,包括对应metric下所有tagk的值。

注意事项

创建表时,不需要指定timestamp和value字段,系统会根据指定的tags自动构建字段,包含以下字段,其中TAG1和TAG2由tags指定。

  • TAG1 String
  • TAG2 String
  • timestamp Timestamp
  • value double

示例

创建opentsdb_table表并关联到OpenTSDB组件的city.temp这个metric。

CREATE table opentsdb_table using opentsdb OPTIONS ('metric'='city.temp',  'tags'='city,location');