iox.sql() function

iox.sql() executes an SQL query against a bucket in an IOx storage node.

This function creates a source that reads data from IOx.

Function type signature

(bucket: string, query: string) => stream[A] where A: Record

Parameters

bucket

(Required) IOx bucket to read data from.

query

(Required) SQL query to execute.

Examples

Use SQL to query data from IOx

import "experimental/iox"

iox.sql(bucket: "example-bucket", query: "SELECT * FROM measurement")