data-engineering-streaming
Real-time data pipelines with Apache Kafka, MQTT (IoT), and NATS JetStream. Covers producers, consumers, streaming patterns, and integration with data…
Find an Agent Skill for your task. Read the guide and copy the install command.
Updated 11-02 00:09
17,277 results
Real-time data pipelines with Apache Kafka, MQTT (IoT), and NATS JetStream. Covers producers, consumers, streaming patterns, and integration with data…
Model evaluation and validation: cross-validation, metrics, hyperparameter tuning, and model comparison. Use when assessing model performance, selecting…
Create and manage data pipelines using the FlowerPower framework with Hamilton DAGs and uv. Lightweight orchestration for batch ETL, data transformation, and…
Unified query of financial data such as stocks and cryptocurrencies. Supports multiple data sources including Yahoo Finance, Alpha Vantage, Tushare, and Binance. Use when users need market data, quotes, or financial data.
NBA G League data via ESPN public endpoints, NBA Stats (stats.nba.com, LeagueID 20), and the G League live CDN (cdn-gleague.nba.com) — scores, standings, team…
Use when adding or auditing Schema.org structured data for AI extraction and rich results. Generate JSON-LD for organization, FAQ, HowTo, product, and article…
This skill should be used when analyzing CSV datasets, handling missing values through intelligent imputation, and creating interactive dashboards to visualize…
Analyze user conversion funnels, calculate step-by-step conversion rates, create interactive visualizations, and identify optimization opportunities. Use when…
Invoke when quality-reviewer or test-developer validates CakePHP database changes. Checks migration file syntax, fixture-migration schema consistency,…
Sanitize and anonymize a Simulink model for external sharing. Use when stripping proprietary content, anonymizing block/signal names, removing metadata, or…
Group events by local hour or local day in application code from one raw scan, not in SQL — the engine's local-time modifier answers from the process time zone…
Import thousands of rows from a user-supplied file without the UI going dark or the batch dying halfway — chunk the writes and emit progress per chunk, reject…
Sweeping a local cache database down to what the user actually owns — ordering container deletes before leaf deletes, telling "kept by state" columns apart…
Deleting the dependent rows that exist only to serve a state at the exact transition that ends that state — rather than leaving them to a later bulk sweep —…
Put several measures that share no whole onto concentric arcs instead of slicing one circle between them, cap the largest sweep short of 360°, and draw value…
Reading a type marker the remote source declares for itself — normalizing before every comparison because locally stored rows from older app versions hold…
Split a span into buckets of exactly equal width and let the remainder fall outside, pick the bucket unit from how many rows a person will read, and never draw…
Counting entities encountered for the first time means taking MIN over the entity's whole history and asking whether that minimum lands inside the window — the…
Specify a user-facing exchange file — why a version field can be worse than none, rejecting a file whose parse yields nothing, stating the same-length rule…
Matching a machine-generated id inside a text or JSON column with LIKE — why `_` and `%` in the id silently widen the match, how to escape them with nested…
Build per-user listening or usage analytics entirely on-device — an append-only event table plus a denormalized per-contributor table that carries a copy of…
Estimate a peer's clock offset from ping/pong round trips — take the peer's own processing time out before halving, weight each sample against the best round…
Print the share of input a distribution could actually classify, computed with exactly the predicates that built the buckets, and keep that line reachable when…
Cache a large published index by parsing it into indexed rows once and re-checking it with the server's own ETag, so a routine freshness check costs a couple…