docs-v2

2.1 KiB

Raw Permalink Blame History

title

description

weight

flux/v0/tags

clickhouse.query() function

`clickhouse.query()` queries data from ClickHouse using specified parameters.

flux_v0_ref

name	parent	identifier
clickhouse.query	contrib/qxip/clickhouse	contrib/qxip/clickhouse/query

301

inputs

clickhouse.query() queries data from ClickHouse using specified parameters.

Function type signature

(
    query: string,
    ?cors: string,
    ?format: string,
    ?limit: A,
    ?max_bytes: B,
    ?url: string,
) => stream[C] where A: Stringable, B: Stringable, C: Record

{{% caption %}} For more information, see Function type signatures. {{% /caption %}}

Parameters

url

ClickHouse HTTP API URL. Default is http://127.0.0.1:8123.

query

({{< req >}}) ClickHouse query to execute.

limit

Query rows limit. Defaults is 100.

cors

Request remote CORS headers. Defaults is 1.

max_bytes

Query bytes limit. Default is 10000000.

format

Query format. Default is CSVWithNames.

For information about available formats, see ClickHouse formats.

Examples

Query ClickHouse

import "contrib/qxip/clickhouse"

option clickhouse.defaultURL = "https://play@play.clickhouse.com"

clickhouse.query(query: "SELECT version()")

2.1 KiB Raw Permalink Blame History