Skill UI

Automate Amplitude analytics tasks through Composio’s Rube MCP toolkit, covering event ingestion, user activity, property management, cohorts, and schema discovery before each call.

Automate Amplitude analytics tasks through Composio’s Rube MCP toolkit, covering event ingestion, user activity, property management, cohorts, and schema discovery before each call.

This SDK provides comprehensive Python support for interacting with Azure Event Hubs, a high-throughput streaming platform. It allows developers to build robust data ingestion pipelines, acting as both event producers (sending data) and event consumers (receiving data). Key features include efficient batch processing, partition key management, and reliable checkpointing using Azure Blob Storage for production-grade stream applications.

This SDK provides comprehensive Python support for interacting with Azure Event Hubs, a high-throughput streaming platform. It allows developers to build robust data ingestion pipelines, acting as both event producers (sending data) and event consumers (receiving data). Key features include efficient batch processing, partition key management, and reliable checkpointing using Azure Blob Storage for production-grade stream applications.

A comprehensive client library for interacting with Azure Event Hubs in Rust. It facilitates robust data streaming ingestion by providing functionality for both producers (sending event batches) and consumers (receiving and processing events from partitions). Designed for building high-throughput, real-time, event-driven data pipelines and architectures.

A comprehensive client library for interacting with Azure Event Hubs in Rust. It facilitates robust data streaming ingestion by providing functionality for both producers (sending event batches) and consumers (receiving and processing events from partitions). Designed for building high-throughput, real-time, event-driven data pipelines and architectures.

A comprehensive guide and implementation guide for using the Azure Event Hubs SDK in TypeScript. It demonstrates best practices for high-throughput event streaming, including batch event sending, targeted partitioning, and robust event consumption. Covers advanced features like checkpointing, starting from specific positions, and handling event properties, making it ideal for building scalable, real-time data ingestion pipelines.

A comprehensive guide and implementation guide for using the Azure Event Hubs SDK in TypeScript. It demonstrates best practices for high-throughput event streaming, including batch event sending, targeted partitioning, and robust event consumption. Covers advanced features like checkpointing, starting from specific positions, and handling event properties, making it ideal for building scalable, real-time data ingestion pipelines.

A comprehensive Java SDK client for securely and efficiently sending custom application logs to Azure Monitor. It utilizes Data Collection Rules (DCR) and Data Collection Endpoints (DCE) to manage the ingestion process. The client supports batch uploads, concurrent processing, and robust error handling, making it ideal for integrating custom logging into Azure Log Analytics workspaces.

This SDK provides a dedicated Python interface for securely sending custom logs to Azure Monitor Log Analytics workspace. It utilizes the Logs Ingestion API, supporting features like batch compression, advanced error handling, asynchronous uploads, and compatibility with various authentication models, including sovereign clouds.

This guide provides comprehensive patterns and best practices for working with ClickHouse, a high-performance OLAP database. It covers advanced topics such as MergeTree engine design, efficient query optimization (filtering, aggregations, window functions), bulk/streaming data ingestion, materialized view creation, and performance monitoring techniques, ensuring optimal performance for large-scale analytical workloads.

Clarity Gate ensures documents entering RAG knowledge bases retain epistemic quality by generating Clarity-Gated Documents, validating Source of Truth tables, and running deterministic claim/document hash scripts before ingestion.