Create and manage GreptimeDB flows for time-windowed aggregation and materialized views.
npx skills add https://github.com/GreptimeTeam/docs --skill greptimedb-flow
Please help me install this Agent Skill. Skill: greptimedb-flow Source: https://github.com/GreptimeTeam/docs/tree/main/skills/greptimedb-flow Command: npx skills add https://github.com/GreptimeTeam/docs --skill greptimedb-flow
This Skill helps data teams rapidly define, deploy, and validate GreptimeDB flows that perform time-windowed aggregations and maintain materialized views, enabling near real-time analytics.
Use the greptimedb-flow skill to define a new flow with a time window, a source table, and a sink table, then run the generated DDL to establish the flow and verify results.
High-intent search queries and answers about installing and using this skill.
To create continuous aggregation flows in GreptimeDB, you define time windows and aggregation rules, then use generated sink table DDL and FLOW statements to automatically maintain materialized views for streaming workloads.
GreptimeDB flow tasks are used in streaming data pipelines to perform on-the-fly time-windowed aggregation and maintain materialized views, enabling near real-time analytics for data teams.
You can generate DDL for sink tables and flows by specifying a source table, a sink table, and your desired time window, which produces the necessary statements to establish continuous aggregation workflows.
Yes, you can validate GreptimeDB continuous aggregation results in development, testing, and production environments by running generated DDL and referencing common validation scenarios using a local server if available.
A local server is not strictly required but is recommended for verification, as it provides guidance on validating flow expressions and checking sink table results during development and testing.
GreptimeDB flows for materialized views require predefined time windows and aggregation rules, meaning they are designed for structured streaming workloads and may need separate validation steps across different deployment environments.
yunqiqiliangAutomates real-time single-table data synchronization from Kafka, MySQL, PostgreSQL, or SQL Server into Lakehouse.
llmh333Optimize ClickHouse MergeTree table design and query patterns for analytical workloads.
drewid74Ingest ADS-B, AIS, and APRS feeds into PostGIS geospatial events.
hung-phanProcess unbounded event streams with deterministic results and bounded state.
