# Greptimedb Flow

> Guide for creating GreptimeDB flow tasks, for generates materialized view for continuous aggregation. Use when this capability is needed.

- Skill: `tomevault-io/greptimedb-flow` (Agent Skill, multi-file: 2 files)
- Install (CLI): `npx skillmds@latest add tomevault-io/greptimedb-flow`
- Raw SKILL.md: https://api.skillmd.com/api/skills/tomevault-io/greptimedb-flow/raw
- Safety review: pending (external: skill-scanner PASS, skillspector PASS)
- Works with: Claude Code, Claude.ai, OpenAI Codex
- Category: Coding & Dev Tools
- Author: tomevault-io (https://skillmd.com/u/tomevault-io)
- Updated: 2026-09-17
- Page: https://skillmd.com/skills/tomevault-io/greptimedb-flow

---


# GreptimeDB Flow Guide

Create GreptimeDB flow definition to do time window based aggregation on the fly
while data ingested into GreptimeDB. This is how GreptimeDB's lightweight
streaming engine works.

Flow is also known as:

1. Stream computing
2. Materialized View
3. Continuous aggregation

## The workflow

To create GreptimeDB flow task, we should follow these phases:

### Phase 1. Learn and understand GreptimeDB Flow

First, we read GreptimeDB flow definitions and how it works from the
documentation.

There are doc pages available, use WebFetch to load and understand them:

1. Overview and quick example:
   https://docs.greptime.com/user-guide/flow-computation/overview/
2. Examples for continuous aggregation:
   https://docs.greptime.com/user-guide/flow-computation/continuous-aggregation/
3. SQL DDL for flow, sink table and related concepts:
   https://docs.greptime.com/user-guide/flow-computation/manage-flow/

### Phase 2. Create flow tasks

We should try to understand:

1. time window the user wants to use
2. aggregation fields and group-by rules

Create the flow and sink table DDL. Note that we will always provide `CREATE
TABLE` statement for sink table, together with the `CREATE FLOW` statement
because it's required.

### Phase 3. Verify the tasks

If greptimedb-mcp-server is available, we can use its `execute_sql` tools to
execute the DDL. Try to generate some sample data, insert into source table,
then verify the sink table via SQL SELECT statements. We can use MySQL style
SELECT statements on GreptimeDB for most cases.

## Reference

1. Aggregation functions of Flow:
   https://docs.greptime.com/user-guide/flow-computation/expressions/
2. A full list of aggregation functions
   https://docs.greptime.com/reference/sql/functions/df-functions/#aggregate-functions

---
> Converted and distributed by [TomeVault](https://tomevault.io/claim/greptimeteam) — claim your Tome and manage your conversions.
<!-- tomevault:4.0:skill_md:2026-04-11 -->