Allium MCP connector

• Create Create a Allium querie run Execute a saved allium query by its query_id and return the results. The request body is a free-form JSON object that maps query parameter names to string values; the required keys depend on the saved query's parameter definitions. Returns query execution results as a dynamic payload whose schema depends on the query's column definitions. Required: query_id.
• Create Create a Allium querie run async Execute an Allium Explorer query asynchronously and receive a run identifier for polling results. Returns: run_id. Required: query_id.
• List List all Allium explorer query runs Get the latest query run for a given query in allium. Returns: run_id, query_id, query_config, creator_id, created_at, completed_at, status, stats, error, results, zed_token. Required: query_id.
• Search Allium explorer query runs cancel Cancel a running query run in allium by run_id. Returns a 200 response on success; the response body structure is not enumerated by the source. Required: run_id.
• List List all Allium query run status Get the current execution status of an Allium Explorer query run. Returns a status string indicating the run's progress — one of: created, queued, running, success, failed, or canceled. Required: run_id.
• List List all Allium query run results List results of a completed Allium Explorer query run. Returns: sql, data, meta, queried_at, run_id. Required: run_id.
• List List all Allium polygon nfts List NFTs on the Polygon blockchain via Allium. Returns: id, created_at, updated_at.
• List List all Allium pings List pings in allium. Returns: id, name, created_at, updated_at.
• Create Create a Allium token price Fetch the latest price and OHLC values for a list of tokens in allium. Returns an items array with each token's timestamp, chain, address, price, open, high, close, low, and decimals, plus a cursor and message. Required: a request body array of token_address and chain pairs (up to 200 tokens).
• Get Get single Allium token price by ID Get token prices at or before a specific timestamp in allium, falling back to the closest prior price when no exact match exists. Returns an items array with input_timestamp, price_timestamp, mint, chain, and price per token, plus a cursor and message. Required: addresses, timestamp, time_granularity.
• Create Create a Allium token price history Fetch historical OHLC price data in allium for up to 50 token/chain pairs over a specified time window. Returns items containing mint, chain, decimals, and a prices array with timestamp, price, open, high, close, and low values; also returns cursor and message. Required: addresses, start_timestamp, end_timestamp, time_granularity.
• Create Create a Allium token price stat Fetch token price statistics for up to 200 tokens in allium based on on-chain DEX activity. Returns: filter. Required: a request body array with token_address and chain per token entry. Maximum 200 tokens per request.
• List List all Allium tokens List the top allium tokens ordered by a specified metric. Returns: chain, address, object, price, decimals, info, attributes. Supports optional filtering by chain and minimum volume thresholds.
• Search Allium tokens search Search allium tokens by keyword matched case-insensitively against token name and symbol. Returns: chain, address, object, price, decimals, info, attributes. Required: q.
• Get Get single Allium token by ID Fetch detailed token data in allium for one or more specific token addresses by supplying an array of chain/address pairs. Returns: object, allocation_amounts, consumed_amounts. Required: token_address, chain (per array item). Accepts 1–200 pairs per request.
• List List all Allium token transfers List token transfers in allium for a given blockchain chain. Returns records including block_slot, block_height, block_timestamp, txn_id, from_account, to_account, from_token_account, to_token_account, mint, value, decimals, and signer. Required: chain. transfer_type filter can only be used when address is also specified.
• List List all Allium assets List assets in Allium. Returns a paginated collection of asset records; each item includes id, slug, source, name, symbol, image_url, circulating_supply, chain_specific_data, and token_creation_time. No required parameters.
• Get Get single Allium asset by ID Get a batch of assets in Allium by ID, slug, or chain and address. Returns an array of asset records each with id, slug, source, name, symbol, image_url, circulating_supply, chain_specific_data, and token_creation_time. Supply at least one lookup field per item in the request body.
• Create Create a Allium wallet balance Fetch the latest fungible token balances for one or more wallet addresses across supported chains in Allium. Returns: address, block_hash, block_number, block_timestamp, chain, raw_balance, raw_balance_str, token. Required: array body with chain and address per entry. Accepts 1–100 wallet entries per request.
• Create Create a Allium wallet balance history Fetch historical fungible token balances for up to 5 wallet addresses in allium. Returns balance records including address, block_hash, block_slot, block_timestamp, chain, raw_balance, raw_balance_str, token, txn_id, and txn_index. Required: addresses, start_timestamp, end_timestamp.
• Create Create a Allium wallet transaction Fetch wallet transactions in allium for one or more wallet address and chain pairs, supporting up to 20 wallets per request. Returns items containing each transaction's id, hash, chain, block_timestamp, fee, from_address, to_address, asset_transfers, and activities, plus a cursor for pagination. Required: request body array with chain and address per wallet.
• Create Create a Allium wallet holdings history Fetch historical USD holdings value for wallet addresses in allium, returning aggregated snapshots at regular time intervals sorted by timestamp descending. Returns: filter. Required: addresses, start_timestamp, end_timestamp, granularity. Accepts 1–15 address/chain pairs per request; the finest allowed granularity depends on the requested time range.
• Create Create a Allium wallet pnl Fetch current PnL metrics for one or more wallet addresses in allium. Returns: filter. Accepts 1–20 wallet/chain pairs per request. Required: array body with chain and address for each entry.
• Create Create a Allium wallet pnl history Fetch historical realized and unrealized PnL for wallet addresses in Allium over a specified time range and granularity. Returns: filter. Required: addresses, start_timestamp, end_timestamp, granularity. Addresses array is limited to 1–20 entries; allowed granularity depends on the requested time range.
• Create Create a Allium wallet pnl by token Fetch current PnL metrics for specific wallet and token address combinations in allium. Returns data and items each containing chain, address, token_address, current_tokens, current_balance, current_price, unrealized_pnl, realized_pnl, average_cost, unrealized_pnl_ratio_change, attributes, and historical_breakdown per token. Required: chain, address, token_address per item. Accepts an array of…
• Create Create a Allium wallet pnl by token history Fetch historical PnL breakdown by token for one or more wallets in allium. Returns data and items arrays each containing chain, address, token_address, and a pnl array of timestamped unrealized_pnl and realized_pnl entries, plus error and cursor. Required: addresses (1–20 wallet/chain/token triples), start_timestamp, end_timestamp, granularity.
• Create Create a Allium wallet position Fetch DeFi wallet positions in allium for up to 5 address/chain pairs in a single request. Returns items (a list of positions with position_id, position_type, protocol, address, chain, total_value_usd, token0, token1, and unclaimed_fees_usd), cursor, and total. Required: chain and address for each entry in the request array.
• Create Create a Allium hyperliquid fill Fetch fill data for a Hyperliquid user address in Allium. Returns an array of fill records including closedPnl, coin, hash, oid, px, side, sz, time, fee, feeToken, tid, liquidation, builderFee, builderAddress, and twapId. Required: type, user. Note: startTime is required when type is userFillsByTime.
• Create Create a Allium hyperliquid order history Fetch historical order data for a Hyperliquid user address via Allium. Returns an array of order records each containing order (with coin, side, limitPx, sz, oid, orderType, tif, cloid, and more), status, and statusTimestamp. Required: type, user. The interval between startTime and endTime cannot exceed 30 days; omit both to retrieve the most recent orders.
• Create Create a Allium hyperliquid order status Get order status information for a Hyperliquid user address. Returns the order object (including coin, side, limitPx, sz, oid, orderType, tif, and cloid), along with status and statusTimestamp. Required: type, user, oid.
• List List all Allium hyperliquid orderbook List all Hyperliquid orderbook snapshots across every trading pair with approximately 5-second data freshness. Returns an array of per-pair snapshots; each snapshot includes pair (trading pair identifier) and book_orders (two-element array of bids at index 0 and asks at index 1), where every order entry contains coin, side, limitPx, sz, oid, timestamp, orderType, tif, reduceOnly, origSz,…
• Create Create a Allium hyperliquid event Retrieve Hyperliquid user event history from Allium, returning funding payments or non-funding ledger updates for a given wallet address. Returns an array of event objects each containing time (Unix ms timestamp), hash (transaction hash), and a delta payload with type-specific fields such as coin, usdc, szi, and fundingRate. Required: type, user.
• List List all Allium markets List allium markets with optional filters by venue, instrument type, base/quote asset, and active status. Returns: market_id, venue, base_asset, quote_asset, settlement, active, tick_size, contract_size, perp.
• Search Allium markets search Search allium markets by free-text query for ticker lookups and symbol disambiguation across venues and instrument types. Returns: market_id, venue, match_type. Required: q (max 1024 characters).
• Get Get single Allium market by ID Get a single allium market by id. Returns `data`, the full market reference object, including market_id, venue, base_asset, quote_asset, settlement, active, tick_size, contract_size, and perp funding metadata. Required: id.
• List List all Allium market prices Get the latest price snapshot for a market in allium. Returns: market_id, as_of, mark, index, mid. Required: market_id, instrument (either `perps` or `spot`, consistent with the market_id). Snapshots are cached for ~60 seconds.
• List List all Allium market ohlcv List historical OHLCV candles for a market in allium. Returns: market_id, open_time, close_time, open, high, low, close, volume, trade_count. Required: market_id, interval, start_timestamp, end_timestamp. Query window is capped at 7 days per request.
• List List all Allium market funding List historical funding rates for a perpetual market in allium, collapsed into hourly buckets. Returns: market_id, ts, funding_rate, premium_index, interval_seconds. Required: market_id, start_timestamp, end_timestamp. Query window is capped at 7 days per request.
• List List all Allium market open interest List open interest timeseries for a perpetual market in allium. Returns: market_id, ts, oi_base, oi_quote_usd. Required: market_id, interval, start_timestamp, end_timestamp. Query window is capped at 7 days per request.
• List List all Allium market liquidations List historical liquidation events for a perpetual market in allium, returned newest first. Returns: market_id, ts, size_base, price, notional_usd, side. Required: market_id, start_timestamp, end_timestamp. Query window is capped at 7 days per request.
• List List all Allium organization usage Get your Allium organization's current unit usage for the active billing and allocation period. Returns: billing_period_start, billing_period_end, allocation_period_start, allocation_period_end, allocation_cadence, allocation_amounts, consumed_amounts.
• List List all Allium beam configs List all allium Beam pipeline configurations accessible to the authenticated user. Returns an array of BeamConfig objects, each including id, name, description, pipeline_config, owner_org_team_user_id, organization_id, tags, static_egress_ip, pod_size, created_at, and updated_at.
• Create Create a Allium beam config Create a new allium Beam pipeline configuration. Returns the created BeamConfig including id, name, description, owner_org_team_user_id, pipeline_config, organization_id, created_at, updated_at, tags, static_egress_ip, and pod_size. Required: name, description, pipeline_config.
• Get Get single Allium beam config by ID Get a single allium Beam pipeline configuration by id. Returns the full BeamConfig object including id, name, description, pipeline_config, owner_org_team_user_id, organization_id, created_at, updated_at, tags, static_egress_ip, and pod_size. Required: id.
• Update Update a Allium beam config by ID Update an existing allium Beam pipeline configuration by id. Returns the updated BeamConfig including id, name, description, owner_org_team_user_id, pipeline_config, organization_id, created_at, updated_at, tags, static_egress_ip, and pod_size. Required: id, name, description, owner_org_team_user_id, pipeline_config.
• Delete Delete a Allium beam config by ID Delete an allium Beam pipeline configuration by id, permanently removing the config and tearing down all active deployment resources including Kafka topics, workers, and subscriptions. Returns: message. Required: id.
• List List all Allium beam sources List all available Allium Beam pipeline sources — the catalog of chain/entity combinations that can be used as a Beam pipeline input. Returns: chain, entity, is_zerolag. Optionally filter by chain, entity, or zerolag.
• Create Create a Allium beam deployment Deploy an Allium Beam pipeline config, creating Kafka topics, provisioning credentials, and spinning up workers. Deployment is idempotent — safe to call again after updating a config to apply changes with zero downtime. Returns: message. Required: config_id.
• Delete Delete a Allium beam deployment by ID Tear down a deployed Allium Beam pipeline, removing workers, Kafka topics, and subscriptions while preserving the pipeline config for future redeployment. Returns: message. Required: config_id.
• List List all Allium beam deployment stats Get deployment stats for an Allium Beam pipeline configuration. Returns workers_health containing total_workers, healthy_workers, unhealthy_workers, crashing_workers, oom_killed_workers, and a workers array with per-worker fields including name, status, is_ready, is_crash_looping, is_oom_killed, restart_count, and start_time. Required: config_id.
• List List all Allium beam deployment metrics List Allium Beam pipeline deployment metrics. Aggregated mode returns pipeline_id, messages_received_per_min, messages_sent_per_min, total_latency, processing_latency, processor_error_rate, output_error_rate, and data_freshness_ms. Time-series mode returns config_id and a metrics array with timestamped data points. Required: config_id.
• Update Update a Allium beam transform by ID Update a single transform in an allium Beam pipeline by id. The pipeline is automatically redeployed after the update. Returns: script, uid. Required: config_id, id.
• Action Allium beam transforms replace Get a single allium Beam transform by id within a pipeline config. Returns: script, uid. Required: config_id, id.
• Update Allium beam transforms partial update List all transforms configured for an allium Beam pipeline. Returns an array of transform objects each containing script, uid, and type. Required: config_id.
• Update Allium beam transforms bulk update Replace all transforms for an allium Beam pipeline in a single call, handling add, remove, update, and reorder. The pipeline is automatically redeployed. Returns: added. Required: config_id. The transforms list cannot be empty; omit uid on new transforms to auto-generate one.
• Create Create a Allium beam filter value Add values to an Allium Beam set filter transform. Duplicates are silently ignored and changes take effect immediately without redeploying. Returns: added. Required: config_id, transform_uid, values.
• List List all Allium beam filter values List all values in an Allium Beam set filter transform, returned as a paginated collection. Returns: values, total_count, cursor. Required: config_id, transform_uid.
• Delete Delete a Allium beam filter value by ID Remove specific values from an Allium Beam set filter transform. Changes take effect immediately without redeploying. Returns: removed. Required: config_id, transform_uid, values.
• Update Update a Allium beam filter value by ID Atomically replace all values in an Allium Beam set filter transform. An empty list clears the filter entirely. Changes take effect immediately without redeploying. Returns: count. Required: config_id, transform_uid, values.
• List List all Allium beam filter value count Count the total number of filter values for a specific transform in Allium Beam. Returns the scalar aggregate count of values currently held in the filter. Required: config_id, transform_uid.
• List List all Allium beam filter value check Check whether a specific value exists in a Beam set filter transform in Allium. Returns the checked value and its membership status: value, is_member. Required: config_id, transform_uid, value.
• List List all Allium beam backfills List all allium backfill jobs for the authenticated organization, ordered by creation time. Returns: job_id, workflow_id.
• Create Create a Allium beam backfill Create an allium backfill job that stages data from a Snowflake table for a given time window and streams it to one or more destinations. The job progresses through staging → transporting → completed (or failed/cancelled). Returns: job_id, workflow_id. Required: job_name, table, backfill_window, destinations. Currently only Base tables are supported.
• Cancel Allium beam backfills cancel Cancel a running allium backfill job by job_id. Sends a cancellation signal; the job stops at the next phase boundary and transitions to cancelled, with associated resources torn down automatically. Returns an empty 204 response on success. Required: job_id.
• Create Create a Allium beam dataset Create a new dataset in Allium Beam. Dataset names must be unique per user. Returns: id, name, created_at, updated_at. Required: name.
• List List all Allium beam datasets List all datasets belonging to the authenticated user in Allium Beam. Returns: id, name, created_at, updated_at, count. Optionally filter results to specific datasets by name.
• Delete Delete a Allium beam dataset by ID Permanently delete a dataset and all its entries in Allium Beam by id. This action is irreversible. Returns an empty 204 response on success. Required: id.
• Create Create a Allium beam dataset entry Add string values to an Allium Beam dataset. Duplicates are silently ignored and changes are reflected immediately in lookups without requiring a redeploy. Returns: count. Required: dataset_id, values. Maximum 250,000 values per request.
• List List all Allium beam dataset entries List all entries in an Allium Beam dataset, sorted alphabetically. Returns: values, cursor, total_count. Required: dataset_id.
• Delete Delete a Allium beam dataset entry by ID Remove string values from an Allium Beam dataset. Non-existent values are silently ignored and changes take effect immediately without requiring a redeploy. Returns: count. Required: dataset_id, values.
• Get Get single Allium beam dataset entry by ID Check whether a specific value exists as an entry in an Allium Beam dataset. Returns a single boolean field: exists, indicating whether the looked-up value was found in the dataset. Required: dataset_id, entry.
• Create Create a Allium beam dataset entries by name Add string values to an Allium Beam dataset identified by name. Duplicates are ignored and changes are reflected immediately in beam.contains() lookups. Returns: count. Required: name, values. Each request supports up to 250,000 values.
• Create Create a Allium stream data source Create a new filter data source in allium for use in stream transformations. Returns: message, result_id. Required: name, type, description. The type field accepts string_array, int_array, or float_array.
• List List all Allium stream data sources List all filter data sources in allium. Returns: id, name, description, message, result_id.
• Get Get single Allium stream data source by ID Get a single allium filter data source by id. Returns: id, name, description. Required: id.
• Delete Delete a Allium stream data source by ID Delete an allium filter data source by id. Returns: message, result_id. Required: id.
• Update Update a Allium stream data source value by ID Add or remove string values from a filter data source in allium. Returns: message. Required: data_source_id, operation, values.
• List List all Allium stream data source values List the string values stored in a filter data source in allium. Returns: message. Required: data_source_id.
• Create Create a Allium stream filter Create a new stream filter in allium for use in data stream transformations. Supports comparison operators (=, !=, >, >=, <, <=), the `in` operator for arrays or data sources, the `exists` operator for field-presence checks, and compound AND/OR logic. Returns: message, result_id, filter. Required: filter.
• List List all Allium stream filters List all allium stream filters. Optionally narrow results to a specific filter using the id query parameter. Returns: id, filter. The filter object contains the filter definition and may include field, operator, and value (simple filter), op and conditions (compound filter), or type and data_source_id (data-source filter).
• Get Get single Allium stream filter by ID Get a single allium stream filter by id. Returns: id, filter. The filter object contains the filter definition and may include field, operator, and value (simple filter), op and conditions (compound filter), or type and data_source_id (data-source filter). Required: id.
• Update Update a Allium stream filter by ID Update an existing allium stream filter by id, replacing its filter definition. Returns: message, result_id. Required: id, filter.
• Delete Delete a Allium stream filter by ID Delete an allium stream filter by id. Returns: message, result_id. Required: id.
• Create Create a Allium stream workflow Create a new allium workflow that connects a data source, filter, and destination for stream processing. Returns: id, filter_id, data_source_config, data_destination_config, description, external_workflow_id. Required: filter_id, data_source_config, data_destination_config. For PUSH delivery, webhook_url must also be provided inside data_destination_config.
• List List all Allium stream workflows List all allium workflows. Returns an array of workflow objects each including id, filter_id, data_source_config, data_destination_config, description, and external_workflow_id.
• Get Get single Allium stream workflow by ID Get a single allium workflow by id. Returns: id, filter_id, data_source_config, data_destination_config, description, external_workflow_id. Required: id.
• Update Update a Allium stream workflow by ID Update an existing allium workflow by id. Only filter_id and description can be modified. Returns: id, filter_id, data_source_config, data_destination_config, description, external_workflow_id. Required: id, filter_id.
• Delete Delete a Allium stream workflow by ID Delete an allium workflow by id. Returns: message. Required: id.
• Create Create a Allium explorer query Create a new saved Explorer query in Allium programmatically without using the Allium App interface. Returns: filter. Required: title, config. Maximum exportable rows is 250,000; this limit can be increased on request.
• Update Update a Allium explorer query by ID Update an existing saved Explorer query in Allium by id. Modify the SQL, row limit, parameters, or compute profile of a previously created query. Returns: run_id. Required: id.

No tools match your search.