Skardi CLI

CLI for running SQL queries against local files, remote object stores, datalake formats, and databases. No server required.

Install

From the repo root:

cargo install --locked --path crates/cli

Then run skardi from anywhere.

--locked tells cargo to respect the checked-in Cargo.lock instead of re-resolving transitive dependencies. Without it, cargo may pull a newer version of a transitive crate whose MSRV is higher than yours. If that happens, add --locked or upgrade your toolchain.

Run without installing

From the repo root:

cargo run -p skardi-cli -- <command> [options]

Commands

query — Run SQL or show schema

Execute a SQL query or show table schema(s). Data sources can come from:

• Local files — CSV, Parquet, JSON/NDJSON (directly by path in SQL or via context file)
• Remote files — S3, GCS, Azure Blob, HTTP/HTTPS, OSS, COS (directly by URL in SQL or via context file)
• Datalake formats — Lance (directly by path in SQL or via context file), Iceberg (via context file)
• Databases — PostgreSQL, MySQL, SQLite, MongoDB (via context file or direct path for SQLite)

Query files directly (no context file needed)

You can query local or remote files directly by referencing their paths in SQL — no context file or pre-registration required:

# Local files
skardi query --sql "SELECT * FROM './data/products.csv' LIMIT 10"
skardi query --sql "SELECT * FROM '/absolute/path/events.parquet'"
skardi query --sql "SELECT * FROM './data/logs.json'"

# Lance datasets
skardi query --sql "SELECT * FROM './embeddings.lance' LIMIT 5"

# SQLite tables (pattern: path/to/file.db.table_name)
skardi query --sql "SELECT * FROM './data/my_database.db.users'"
skardi query --sql "SELECT * FROM './data/app.sqlite.customers'"

# Remote files (S3, GCS, Azure)
skardi query --sql "SELECT * FROM 's3://mybucket/data/events.parquet'"
skardi query --sql "SELECT * FROM 'gs://mybucket/data.csv'"
skardi query --sql "SELECT * FROM 'az://mycontainer/data.parquet'"
skardi query --sql "SELECT * FROM 'https://example.com/data.csv'"

# Join across sources
skardi query --sql "
  SELECT a.*, b.score
  FROM './users.csv' a
  JOIN 's3://mybucket/scores.parquet' b ON a.id = b.user_id
"

Remote storage credentials are read from standard environment variables (e.g., AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_REGION for S3; GOOGLE_SERVICE_ACCOUNT for GCS; AZURE_STORAGE_ACCOUNT_NAME, AZURE_STORAGE_ACCESS_KEY for Azure).

Supported remote schemes: s3://, gs://, gcs://, az://, azure://, abfs://, abfss://, http://, https://, oss:// (Alibaba), cos:// (Tencent)

Query with a context file

For database sources or when you want named tables, use a context file:

# Inline SQL
skardi query --ctx <path-to-ctx.yaml> --sql "SELECT * FROM my_table LIMIT 10"

# SQL from file
skardi query --ctx <path-to-ctx.yaml> --file query.sql
skardi query -f ./queries/report.sql

# With default ctx — SKARDICONFIG accepts a directory (preferred) or a
# single ctx file. When it's a directory, the CLI also looks inside it for
# `aliases.yaml` and `pipelines/`.
export SKARDICONFIG=/path/to/config-dir
# or point at a single file
export SKARDICONFIG=/path/to/ctx.yaml
skardi query --sql "SELECT * FROM my_table"
skardi query --file report.sql

Context resolution (when --ctx is omitted): SKARDICONFIG env, then ~/.skardi/config/. Both --ctx and SKARDICONFIG accept either a file (used directly) or a directory (the CLI appends ctx.yaml by convention). If no context file is found, the query runs without pre-registered tables (you can still query files directly by path).

Schema inspection

Use --schema with either --all (all tables) or -t TABLE (one table):

skardi query --ctx ./demo/ctx.yaml --schema --all
skardi query --ctx ./demo/ctx.yaml --schema -t products

Context file format

data_sources:
  # Local CSV
  - name: products
    type: csv
    path: data/products.csv
    options:
      has_header: true
      delimiter: ","
      schema_infer_max_records: 1000

  # Local Parquet
  - name: events
    type: parquet
    path: data/events.parquet

  # Remote Parquet (S3)
  - name: remote_events
    type: parquet
    path: s3://mybucket/data/events.parquet

  # JSON / NDJSON
  - name: logs
    type: json
    path: data/logs.json

  # Lance dataset
  - name: embeddings
    type: lance
    path: data/embeddings.lance

  # Iceberg table
  - name: transactions
    type: iceberg
    path: s3://warehouse/path
    options:
      namespace: my_db
      table: transactions
      aws_region: us-east-1

  # PostgreSQL
  - name: users
    type: postgres
    connection_string: postgresql://localhost:5432/mydb
    options:
      table: users
      schema: public
      user_env: PG_USER
      pass_env: PG_PASS

  # MySQL
  - name: orders
    type: mysql
    connection_string: mysql://localhost:3306/mydb
    options:
      table: orders
      user_env: MYSQL_USER
      pass_env: MYSQL_PASS

  # SQLite
  - name: users
    type: sqlite
    path: data/my_database.db
    options:
      table: users
      busy_timeout_ms: "5000"   # Optional

  # MongoDB
  - name: profiles
    type: mongo
    connection_string: mongodb://localhost:27017
    options:
      database: mydb
      collection: profiles
      primary_key: _id

Supported types:

Type	Source	Path / Connection
csv	Local or remote CSV files	File path or remote URL
parquet	Local or remote Parquet files	File path or remote URL
json / ndjson	Local or remote JSON files	File path or remote URL
lance	Lance vector datasets	Local path
iceberg	Apache Iceberg tables	Warehouse path (local or S3)
postgres	PostgreSQL tables	postgresql://host:port/db
mysql	MySQL tables	mysql://host:port/db
sqlite	SQLite tables	Local file path (e.g. data/my.db)
mongo	MongoDB collections	mongodb://host:port

Path resolution: Relative paths in the context file are resolved relative to your current working directory.

Database credentials: For security, database credentials are supplied via environment variables (specified in options as user_env / pass_env), not in the connection string.

Vector search with lance_knn

The lance_knn table function is built-in and lets you run K-nearest-neighbor searches against Lance datasets.

The Lance dataset must be registered first — either via a context file or by querying it by path (which auto-registers it under the file stem as the table name). For example, querying './embeddings.lance' registers it as embeddings.

-- Syntax: lance_knn(table_name, vector_column, query_vector, k [, filter])

Arguments:

1. table_name (string) — Name of the registered Lance table
2. vector_column (string) — Column containing the vectors
3. query_vector (array or subquery) — The query vector to search for
4. k (integer) — Number of nearest neighbors to return
5. filter (string, optional) — SQL filter predicate applied before KNN search

The result includes all columns from the table (except the vector column) plus a _distance column.

Using with a context file:

# ctx.yaml
data_sources:
  - name: embeddings
    type: lance
    path: data/embeddings.lance

skardi query --ctx ./ctx.yaml --sql "
  SELECT id, label, _distance
  FROM lance_knn('embeddings', 'vector', [0.1, 0.2, 0.3], 5)
"

Using with direct path (no context file):

First reference the Lance dataset in a query so it gets auto-registered, then use lance_knn with the derived table name (file stem):

# The path './embeddings.lance' auto-registers as table name 'embeddings'
skardi query --sql "
  SELECT * FROM lance_knn('embeddings', 'vector',
    (SELECT vector FROM './embeddings.lance' WHERE id = 42), 10)
"

More examples:

-- KNN with a literal vector
SELECT * FROM lance_knn('embeddings', 'vector', [0.1, 0.2, 0.3, ...], 10)

-- KNN with a subquery vector
SELECT * FROM lance_knn('embeddings', 'vector',
    (SELECT vector FROM embeddings WHERE id = 42), 10)

-- KNN with a pre-filter
SELECT * FROM lance_knn('embeddings', 'vector', [0.1, 0.2, ...], 10,
    'category = ''electronics''')

Full-text search with lance_fts

The lance_fts table function is built-in and lets you run full-text search (BM25) against Lance datasets with a full-text index.

Like lance_knn, the Lance dataset must be registered first — either via a context file or by querying it by path (which auto-registers it under the file stem as the table name).

-- Syntax: lance_fts(table_name, text_column, search_query, limit)

Arguments:

1. table_name (string) — Name of the registered Lance table
2. text_column (string) — Column containing the text to search
3. search_query (string) — The search query (see query syntax below)
4. limit (integer) — Maximum number of results to return

The result includes all columns from the table plus a _score column with BM25 relevance scores.

Query syntax:

Syntax	Example	Description
Term search	'umbrella train'	OR logic across terms, ranked by BM25
Phrase search	'"train to boston"'	Exact phrase match
Fuzzy search	'rammen~1'	Typo-tolerant (edit distance 1–2)
Boolean search	'+umbrella -train'	+ = must include, - = must exclude

Using with a context file:

# ctx.yaml
data_sources:
  - name: products
    type: lance
    path: data/products.lance

skardi query --ctx ./ctx.yaml --sql "
  SELECT id, description, _score
  FROM lance_fts('products', 'description', 'wireless headphones', 10)
"

Using with direct path (no context file):

# The path './products.lance' auto-registers as table name 'products'
skardi query --sql "
  SELECT * FROM lance_fts('products', 'description', 'wireless headphones', 10)
"

More examples:

-- Term search
SELECT * FROM lance_fts('products', 'description', 'umbrella', 10)

-- Phrase search
SELECT * FROM lance_fts('products', 'description', '"noise cancelling"', 10)

-- Fuzzy search
SELECT * FROM lance_fts('products', 'description', 'headphnes~1', 10)

-- Boolean search
SELECT * FROM lance_fts('products', 'description', '+wireless -bluetooth', 10)

-- With WHERE filter
SELECT * FROM lance_fts('products', 'description', 'premium', 50)
WHERE category = 'electronics' AND price < 20

run — Execute a pipeline YAML by name

A pipeline is a named SQL template stored in a YAML file:

# demo/llm_wiki/cli/pipelines/list.yaml
metadata:
  name: "wiki-list"
query: |
  SELECT slug, title, page_type, updated_at
  FROM wiki.main.wiki_pages
  WHERE page_type LIKE {page_type_pattern}
    AND slug      LIKE {slug_prefix}
  ORDER BY updated_at DESC
  LIMIT {limit}

{name} placeholders are substituted at call time. Each parameter must be bound via --param NAME=VALUE; values are rendered as SQL-safe literals before DataFusion sees the query (strings are single-quoted with ' → '' escaping, so quotes inside values can't break out).

The examples below use SKARDICONFIG so --ctx doesn't have to be repeated on every line. --ctx PATH still works and takes precedence over the env var, per the resolution order at the top of this README.

export SKARDICONFIG=./demo/llm_wiki/cli

skardi run wiki-list \
  --param 'page_type_pattern=%' \
  --param 'slug_prefix=concept/%' \
  --param 'limit=10'

Pipeline discovery — the CLI scans a single directory for *.yaml / *.yml files, resolved in this order:

1. --pipeline-dir <DIR> flag.
2. pipelines_dir: key in the ctx YAML (relative paths resolve against the ctx file's directory).
3. <config-dir>/pipelines/ by convention, where <config-dir> is the dir SKARDICONFIG (or --ctx) points at (or the parent of the ctx file if it's given as a file path). Only used when the directory exists.
4. Otherwise, no pipelines are registered.

Most projects just drop a pipelines/ directory next to ctx.yaml and get discovery for free; set pipelines_dir: if you want them somewhere else.

Minimal layout:

my-project/
  ctx.yaml
  aliases.yaml      # optional
  pipelines/
    search.yaml
    ...

Then export SKARDICONFIG=./my-project makes every skardi run and alias invocation pick up the ctx, the aliases, and the pipelines automatically.

Parameter typing — --param NAME=VALUE is parsed with serde_json, so the resulting ScalarValue matches what the server would bind if the same value appeared in a JSON request body. This keeps pipeline YAMLs portable between skardi run and an HTTP /pipeline/execute call:

CLI	Server JSON equivalent	Bound type
--param foo=42	{"foo": 42}	Int64
--param foo=3.5	{"foo": 3.5}	Float64
--param foo=true	{"foo": true}	Boolean
--param foo=null	{"foo": null}	Utf8(NULL)
--param foo=hello	{"foo": "hello"}	Utf8
--param 'foo:str=42'	{"foo": "42"}	Utf8

Force a specific type explicitly with NAME:TYPE=VALUE when the JSON form is ambiguous (e.g. a string that happens to look like a number):

# Force "42" to be a string even though it parses as an int
skardi run my-pipeline --param 'query:str=42' --param 'limit:int=10'

Supported explicit types: str / string, int / i64, float / f64, bool. Because parsing is strict JSON, TRUE / True are not booleans (only lowercase true / false are), and numbers must have a leading digit (0.5, not .5) — both matching what the server accepts.

alias — Bind a short verb to a pipeline

Aliases let you replace skardi run wiki-search-hybrid --query="..." --text_query="..." ... with a one-word verb like skardi grep "...". They are a CLI-only concept: the server does not read alias files. Any unknown subcommand is looked up in the alias store, resolved to a pipeline + params, and dispatched to the same code path as skardi run.

Add an alias

export SKARDICONFIG=./demo/llm_wiki/cli

skardi alias add grep \
  --pipeline wiki-search-hybrid \
  --positional query \
  --default 'text_query={query}' \
  --default 'vector_weight=0.5' \
  --default 'text_weight=0.5' \
  --default 'limit=10' \
  --description "Hybrid search over the wiki"

Flags:

• --pipeline <NAME> (required) — metadata.name of the pipeline to call.
• --positional <NAMES> — comma-separated pipeline-param names to bind to positional CLI args in order (e.g. --positional query,text_query).
• --default <NAME=VALUE> (repeatable) — default value for a param. May contain {other} tokens that are substituted from an already-bound param (one level), so a single positional can fan out to multiple params.
• --description <TEXT> — optional short help string shown in alias list.
• --force — overwrite an existing alias with the same name.

The bare form is also useful — skardi alias add grep --ctx ... --pipeline wiki-search-hybrid saves an alias with no positional/default bindings. Callers then pass every pipeline param as a --name=value flag at call time; skardi grep --help will list them.

When the pipeline YAML can be located via the ctx's pipelines_dir:, the CLI parses its {name} placeholders and:

• rejects --positional / --default names that don't match a real parameter (so --default txt_query=... fails fast with the known-params list instead of silently creating a broken alias), and
• prints which params are covered by this alias and which remain unbound — those either need --defaults now or flag overrides at call time.

Example output:

$ skardi alias add grep --pipeline wiki-search-hybrid --positional query
Pipeline 'wiki-search-hybrid' has 5 parameter(s): query, text_query, vector_weight, text_weight, limit
  Unbound by this alias: text_query, vector_weight, text_weight, limit (pass at call time with --name=value, or re-run `alias add --force` with --default/--positional)
Alias 'grep' → pipeline 'wiki-search-hybrid' saved to ./demo/llm_wiki/aliases.yaml

If the pipeline can't be located (e.g. the alias is being authored before the pipeline is), validation is skipped with a note: — the alias is still saved.

Now grep is a first-class verb:

skardi grep "turing machine"
# → skardi run wiki-search-hybrid \
#     --param 'query=turing machine' \
#     --param 'text_query=turing machine' \
#     --param 'vector_weight=0.5' \
#     --param 'text_weight=0.5' \
#     --param 'limit=10'

# Flag overrides beat positional/default bindings
skardi grep "turing machine" --text_query='bletchley OR enigma' --limit=3

Positional args bind in order to alias.positional. Extra positional args error. --name=value / --name value flags always win over positional binds and defaults.

Inspect an alias — skardi <alias> --help or alias show

Both commands print the alias's bindings and the target pipeline's full parameter list, annotated with where each param gets its value. Use --help when invoking an alias to discover its interface; use alias show for the underlying YAML plus the same annotations.

$ skardi grep --help
skardi grep — runs pipeline `wiki-search-hybrid`

Hybrid search over the wiki

Positional args:
  <query>   binds pipeline param `query` (positional[0])

Pipeline params (override at call time with --name=VALUE):
  --query          bound positionally (positional[0])
  --text_query     default: "{query}"
  --vector_weight  default: "0.5"
  --text_weight    default: "0.5"
  --limit          default: "10"

Control flags:
  --ctx <PATH>       Context YAML (SKARDICONFIG env / ~/.skardi/config/ctx.yaml)
  --aliases <PATH>   Override aliases file
  --pipeline-dir <DIR>  Override pipeline discovery directory

Example: skardi grep <query>

skardi alias show grep prints the same information with the alias YAML on top.

List / remove

skardi alias list
skardi alias remove grep

Alias file resolution

The aliases YAML is resolved in this order:

1. --aliases <PATH> flag.
2. SKARDI_ALIASES env var.
3. <config-dir>/aliases.yaml (only if it already exists). The config dir is whatever --ctx or SKARDICONFIG points at — a directory is used directly, a file uses its parent.
4. ~/.skardi/config/aliases.yaml.

The file is a simple top-level map keyed by alias name:

# demo/llm_wiki/cli/aliases.yaml
grep:
  pipeline: wiki-search-hybrid
  positional: [query]
  defaults:
    text_query: "{query}"
    vector_weight: "0.5"
    limit: "10"
  description: Hybrid search over the wiki
ls:
  pipeline: wiki-list
  defaults:
    page_type_pattern: "%"
    slug_prefix: "%"
    limit: "100"

Hand-editing the file is fine — skardi alias add is just a convenience that round-trips through serde.

Examples

# Simple query (no context file needed)
skardi query --sql "SELECT 1"

# Query a local file directly
skardi query --sql "SELECT count(*) FROM './data/products.csv'"

# Query a remote parquet file
skardi query --sql "SELECT * FROM 's3://mybucket/events.parquet' LIMIT 10"

# Query a Lance dataset
skardi query --sql "SELECT * FROM './embeddings.lance' LIMIT 5"

# Query a SQLite table directly
skardi query --sql "SELECT * FROM './data/app.db.users' LIMIT 10"

# With context file (set once; --ctx PATH also works and takes precedence)
export SKARDICONFIG=./demo/llm_wiki/cli

# Query against the exported ctx
skardi query --sql "SELECT * FROM wiki.main.wiki_pages LIMIT 5"

# Show schema
skardi query --schema --all
skardi query --schema -t wiki_pages

# SQL from file
skardi query -f ./queries/report.sql

# Run a pipeline YAML by name, passing named parameters
skardi run wiki-list \
  --param 'page_type_pattern=entity' --param 'slug_prefix=%' --param 'limit=20'

# Invoke a user-defined alias (dispatches to `skardi run <pipeline>`)
skardi grep "turing machine"

# Manage aliases
skardi alias list
skardi alias show grep