将结果转换为 JSON
此示例使用 NOAA 水样本数据。
使用 HTTP POST 方法将每条记录发送到 URL 端点。此示例使用 json.encode() 将值转换为 JSON 字节，然后使用 http.post() 将它们发送到 URL 端点。
以下查询
- 使用
filter()过滤average_temperature测量值。 - 使用
mean()计算结果的平均值。 - 使用
map()创建一个新列jsonStr，并使用查询中的列值构建一个 JSON 对象。然后，它对 JSON 对象进行字节编码，并将其作为字符串存储在jsonStr列中。 - 使用
http.post()将每条记录的jsonStr值发送到 HTTP 端点。
import "http"
import "json"
from(bucket: "noaa")
|> filter(fn: (r) => r._measurement == "average_temperature")
|> mean()
|> map(fn: (r) => ({r with jsonStr: string(v: json.encode(v: {"location": r.location, "mean": r._value}))}))
|> map(
fn: (r) => ({
r with
status_code: http.post(
url: "http://somehost.com/",
headers: {x: "a", y: "b"},
data: bytes(v: r.jsonStr)
)
})
)
此页是否对您有帮助？
感谢您的反馈！