Results for “alternate-data-streams”

Build event streaming applications using Azure Event Hubs SDK for JavaScript (@azure/event-hubs). Use when implementing high-throughput event ingestion, real-time analytics, IoT telemetry, or event-driven architectures with partitioned consumers.

Stream-JSON chaining for multi-agent pipelines, data transformation, and sequential workflows

Debug and modify agent streaming behavior, covering SSE and plain-text transports, ChatKit events, and session continuity.

Data pipeline patterns — ETL/ELT, batch vs streaming, idempotency, orchestration. Use when designing a data pipeline, choosing between batch and streaming, implementing ingestion or transformation, setting up orchestration, or debugging pipeline failures.

Monitor and react to content distribution lifecycle events using the Sling Distribution API, covering event handling, queue monitoring, and distribution tracking.

Detect anomalies in time-series data using the Azure AI Anomaly Detector SDK for Java, with support for univariate and multivariate analysis, model training, and inference.

Ingest and process high-throughput event streams using Azure Event Hubs SDK for Python, with support for producers, consumers, and checkpointing.

Send and receive high-throughput event streams using Azure Event Hubs with .NET, including batch sending, buffered producers, and checkpoint-based processing.

Call APIs, load data into components, and handle the async lifecycle in Blazor.

Migrate AEM Cloud Service resource listeners to the lightweight ResourceChangeListener + JobConsumer pattern, covering migration from legacy APIs, OSGi configuration, troubleshooting, and review checklists.

Migrate AEM replication code from legacy CQ Replicator and Sling Replication Agent APIs to the Sling Distribution API for AEM as a Cloud Service, covering agent selection, async handling, and service-user setup.

Server-Sent Events for real-time server-to-client streaming. Express, Fastify, FastAPI, Spring WebFlux SSE implementations. Event streams, reconnection, and EventSource API. USE WHEN: user mentions "SSE", "Server-Sent Events", "EventSource", "event stream", "text/event-stream", "live feed", "streaming updates" DO NOT USE FOR: bidirectional communication - use `socket-io`; WebRTC - use `webrtc`; LLM streaming - use AI SDK skills

sse-streaming

Advanced Tauri event patterns for bidirectional communication, streaming data, window-to-window messaging, and custom event handling

Async data-fetching patterns — Fetch vs Axios, service-layer organisation, AbortController cancellation, and integration with Redux Toolkit's createAsyncThunk for pending/fulfilled/rejected state transitions. Use when writing or reviewing HTTP call sites, standardising loading/error handling, or wiring request cancellation in effects.

Aggregates multiple RSS, Atom, or JSON feeds into a single daily digest with cross-feed deduplication, themed clustering, weighted ranking, and source-status reporting.

Apache Kafka event streaming platform. Covers producers, consumers, topics, partitions, Kafka Streams, and Connect. Use for high-throughput event-driven architectures and real-time data pipelines. USE WHEN: user mentions "kafka", "event streaming", "kafka streams", "consumer groups", "topic partitions", asks about "high throughput messaging", "event sourcing", "log aggregation", "real-time pipelines" DO NOT USE FOR: simple queues - use `rabbitmq` or `activemq`; cloud-native lightweight - use `nats`; AWS-native - use `sqs`; Azure-native - use `azure-service-bus`; GCP-native - use `google-pubsub`

Detect abnormal access patterns in AWS S3, GCS, and Azure Blob Storage by analyzing CloudTrail Data Events, GCS audit logs, and Azure Storage Analytics. Identifies after-hours bulk downloads, access from new IP addresses, unusual API calls, and potential data exfiltration using statistical baselines.

Applies the same change across multiple repositories in parallel using git worktrees, tests, and pull requests.

Use the @steipete/oracle CLI to bundle a prompt plus the right files and get a second-model review (API or browser) for debugging, refactors, design checks, or cross-validation.

Migrates data from MongoDB, PostgreSQL, MySQL, Neo4j, Kafka, and JSONL into SurrealDB with full and incremental CDC synchronization.

Query Google Data Commons for public statistical data aggregated from global sources, resolving geographic entities and pulling time-series statistics. Use when working with demographic data, economic indicators, health statistics, or environmental data — population counts, GDP figures, unemployment rates, disease prevalence — or when resolving places to DCIDs and exploring relationships between statistical entities. Part of the AlterLab Academic Skills suite.

End-to-end data pipeline for empirical research: fetch economic data from APIs (FRED, World Bank, IMF, BLS, OECD, Yahoo Finance), clean and transform raw data, construct strategy-specific variables, and validate panel structure. Use when asked to fetch data, download data, clean data, merge datasets, prepare analysis-ready data.

Search the web, extract URL content, enrich datasets with web-sourced fields, and run deep research reports, prioritizing academic and scientific sources.

Use HasData APIs for web scraping and structured web data extraction.

AI 原生的潜在客户情报和外联流水线。用 agent 驱动的信号评分、共同关系人排名、暖场路径发现、来源语音建模和多渠道外联（邮件、LinkedIn、X），替代 Apollo、Clay 和 ZoomInfo。在用户想找到、评估并联系高价值联系人时使用。

Design asynchronous messaging patterns in Azure using Service Bus, Event Hubs, Event Grid, and Storage Queues. Use this skill when users ask for queueing, pub-sub, event streaming, retries, or decoupled system design. Covers delivery semantics, dead-lettering, idempotency, and monitoring.

Implement HTTP data fetching in Angular v20+ using resource(), httpResource(), and HttpClient. Use for API calls, data loading with signals, request/response handling, and interceptors. Triggers on data fetching, API integration, loading states, error handling, or converting Observable-based HTTP to signal-based patterns.

Apache Airflow, dbt, Prefect, Dagster, and modern data orchestration for production data pipelines

Construye pipelines ETL/ELT con Pandas: extracción, transformación y carga de datos con logging, manejo de errores, idempotencia y opciones de orquestación.

Use Alpaca CryptoDataStream websocket for real-time crypto bars in live trading (OHLC only, volume excluded)

Analyze network traffic, logs, and data flows to detect potential data exfiltration via DNS tunneling, cloud storage uploads, encrypted channels, and other indicators of compromise.

Streams change data capture from Google Cloud Spanner into Redpanda or Kafka using Redpanda Connect's gcp_spanner_cdc input, with partition-aware watermarked delivery and support for Redpanda Enterprise features.

Detect and respond to Adversary-in-the-Middle (AiTM) phishing attacks that use reverse proxy kits like EvilProxy, Evilginx, and Tycoon 2FA to bypass MFA and steal session tokens.

Use HasData APIs for web scraping and structured web data extraction.