首頁
檢索分析服務(wù) Elasticsearch版
產(chǎn)品概述
AliES內(nèi)核
使用TimeStream時序增強功能
TimeStream時序增強引擎API介紹
TimeStream集成InfluxDB寫協(xié)議接口
TimeStream集成InfluxDB寫協(xié)議接口
TimeStream支持按InfluxDB的行協(xié)議寫數(shù)據(jù),實現(xiàn)將InfluxDB的數(shù)據(jù)導入TimeStream。本文介紹將InfluxDB數(shù)據(jù)導入TimeStream的API、使用說明和示例。
前提條件
已創(chuàng)建阿里云Elasticsearch實例,且實例版本為通用商業(yè)版7.10、內(nèi)核版本為1.8.0及以上。具體操作請參見創(chuàng)建阿里云Elasticsearch實例。
請求語法
POST /_time_stream/influx/write?db={index}&precision=ns
{infludb lines data}
請求參數(shù)
參數(shù) | 說明 |
db | TimeStream索引名稱,必選。 |
precision | 精度參數(shù),可選。不傳該參數(shù)則默認為ns,參數(shù)取值范圍為:[n,ns,u,ms,s,m,h]。 |
使用說明
InfluxDB寫協(xié)議格式如下,詳細信息請參見InfluxDB官方文檔。
// Syntax
<measurement>[,<tag_key>=<tag_value>[,<tag_key>=<tag_value>]] <field_key>=<field_value>[,<field_key>=<field_value>] [<timestamp>]
// Example
myMeasurement,tag1=value1,tag2=value2 fieldKey="fieldValue" 1556813561098000000
說明 InfluxDB行協(xié)議寫入的數(shù)據(jù),measurement會轉(zhuǎn)換為一個名為measurement的label字段,如果label中有同名字段,會覆蓋該值。
InfluxDB寫入的數(shù)據(jù)內(nèi)容,存儲在Elasticsearch中的示例如下:
- 寫入內(nèi)容
testInflux,label1=label_value1 metric1=0.5
- 對應Elasticsearch source內(nèi)容
{ "@timestamp": 1669972652000, "labels": { "measurement": "testInflux", "label1": "label_value1" }, "metrics": { "metric1": 0.5 } }
通過InfluxDBx寫協(xié)議接口寫入的數(shù)據(jù),可以通過Elasticsearch search或者TimeStream Prometheus接口查詢。
示例
請求示例
curl -i --user "user:password" "http://xxx:9200/_time_stream/influx/write?db=test_stream" -d "testInflux,label1=label_value1 metric1=0.5"
返回示例
HTTP/1.1 204 No Content
寫入成功時,Response的body為空,http code為204。寫入失敗時,返回結(jié)果與InfluxDB write接口一致。
文檔內(nèi)容是否對您有幫助?