from() 函数
from()
从 InfluxDB 数据源查询数据。
它从指定的 bucket 返回表流。每个唯一的序列都包含在自己的表中。表中的每条记录代表序列中的一个点。
查询远程 InfluxDB 数据源
使用 from()
查询来自远程 InfluxDB OSS 1.7+、InfluxDB Enterprise 1.9+ 和 InfluxDB Cloud 的数据。要查询远程 InfluxDB 源,请包含 host
、token
和 org
(或 orgID
)参数。
from() 不需要导入包
from()
是 influxdata/influxdb
包的一部分,但它是 Flux 序言的一部分,不需要 import 语句或包命名空间。
函数类型签名
(
?bucket: string,
?bucketID: string,
?host: string,
?org: string,
?orgID: string,
?token: string,
) => stream[{A with _value: B, _time: time, _measurement: string, _field: string}]
有关更多信息,请参阅 函数类型签名。
参数
bucket
要查询的 bucket 的名称。bucket
和 bucketID
互斥。
InfluxDB 1.x 或 Enterprise:提供一个空字符串 (""
)。
bucketID
要查询的字符串编码的 bucket ID。bucket
和 bucketID
互斥。
InfluxDB 1.x 或 Enterprise:提供一个空字符串 (""
)。
host
要查询的 InfluxDB 实例的 URL。
请参阅 InfluxDB Cloud 区域 或 InfluxDB OSS URL。
org
组织名称。org
和 orgID
互斥。
InfluxDB 1.x 或 Enterprise:提供一个空字符串 (""
)。
orgID
要查询的字符串编码的组织 ID。org
和 orgID
互斥。
InfluxDB 1.x 或 Enterprise:提供一个空字符串 (""
)。
token
InfluxDB API 令牌。
InfluxDB 1.x 或 Enterprise:如果禁用身份验证,请提供一个空字符串 (""
)。如果启用身份验证,请使用 <username>:<password>
语法提供您的 InfluxDB 用户名和密码。
示例
使用 bucket 名称查询 InfluxDB
from(bucket: "example-bucket")
使用 bucket ID 查询 InfluxDB
from(bucketID: "0261d8287f4d6000")
查询远程 InfluxDB Cloud 实例
import "influxdata/influxdb/secrets"
token = secrets.get(key: "INFLUXDB_CLOUD_TOKEN")
from(
bucket: "example-bucket",
host: "https://us-west-2-1.aws.cloud2.influxdata.com",
org: "example-org",
token: token,
)
此页是否对您有帮助?
感谢您的反馈!