Aggregator Trades - Allium Documentation Hub

The dex.aggregator_trades table contains successful swaps executed by DEX aggregators. DEX aggregators scan multiple decentralized exchanges (DEXs) simultaneously to find the best trading prices and routes for users, often splitting trades across different liquidity sources to optimize for better rates and lower slippage.

Table Details

Property	Value
Table Name	`zora.dex.aggregator_trades`
Table Status	Production-Ready
Unique Key	`block_timestamp`, `unique_id`
Clustering Key(s)	`block_timestamp::date`
Search Optimization	`transaction_hash`, `project`, `transaction_from_address`

This model is not compatible with dex.trades in terms of column coverage. There are integrator fields that are only applicable for dex aggregators.

Unique Key: unique_id

Table Columns

Column Name	Data Type	Description
integrator	VARCHAR(134217728)	Name of the integrator/frontend used for the trade (e.g., matcha, 1inch) inferred from the integrator tag. This will be null if there are no integrator
integrator_tag	VARCHAR(134217728)	Contract address, event log field or other relevant field that is used to indicate the frontend integrator
project	VARCHAR(134217728)	Name of the project. Includes dodo, paraswap, zeroex, cow_protocol, kyberswap_aggregator, tokenlon, openocean.
protocol	VARCHAR(134217728)	DEX protocol or project contract which executed the aggregator trade.
event_name	VARCHAR(134217728)	This field will be null for majority of DEX aggregator trades. Unless the event specifies the pools that the trade was routed through.
contract_address	VARCHAR(42)	The name of the event (or the function call) for this trade.
liquidity_pool_address	VARCHAR(42)	The contract address of the aggregator.
sender_address	VARCHAR(42)	Address of the sender of the swap event log, which can be the Router.
to_address	VARCHAR(42)	Address of the recipient of the swap event.
token_sold_address	VARCHAR(42)	Address of the token sold.
token_sold_name	VARCHAR(134217728)	Name of the token sold.
token_sold_symbol	VARCHAR(134217728)	Symbol of the token sold.
token_sold_amount_raw_str	VARCHAR(134217728)	Amount of token sold (not divided by the number of decimals) in string.
token_sold_amount_raw	FLOAT	Amount of token sold (not divided by the number of decimals).
token_sold_amount_str	VARCHAR(134217728)	token_sold_amount_raw divided by the number of decimals of the token in string.
token_sold_amount	FLOAT	token_sold_amount_raw divided by the number of decimals of the token.
usd_sold_amount	FLOAT	USD value of tokens sold.
token_bought_address	VARCHAR(42)	Token address of the token bought, i.e. the asset acquired from the trade.
token_bought_name	VARCHAR(134217728)	Name of the token bought.
token_bought_symbol	VARCHAR(134217728)	Symbol of the token bought.
token_bought_amount_raw_str	VARCHAR(134217728)	Amount of token bought (not divided by the number of decimals) in string.
token_bought_amount_raw	FLOAT	Amount of token bought (not divided by the number of decimals).
token_bought_amount_str	VARCHAR(134217728)	token_bought_amount_raw divided by the number of decimals of the token in string.
token_bought_amount	FLOAT	token_bought_amount_raw divided by the number of decimals of the token.
usd_bought_amount	FLOAT	USD value of tokens bought.
usd_amount	FLOAT	USD value of the swap. Note that this preferentially selects the price and value of the more reputable token.
extra_fields	VARIANT	This field contains all the extra columns emitted from the event/function call that were not part of the convetional DEX trades columns.
transaction_from_address	VARCHAR(42)	The address of the sending party of this transaction.
transaction_to_address	VARCHAR(42)	The address of the receiving party of this transaction (could be a contract address).
transaction_hash	VARCHAR(66)	Transaction hash of this trade.
transaction_index	NUMBER(38,0)	Transaction index of this trade in the block.
transaction_fees	FLOAT	Fees paid at the transaction level.
transaction_fees_usd	FLOAT	Fees paid in USD.
fee_details	VARIANT	Additional fee details of the transaction, including max priority fee, gas price and gas used for the transaction.
selector	VARCHAR(134217728)	The 4-byte function selector of the aggregator method invoked for this trade.
log_index	NUMBER(38,0)	Log index of this trade.
block_timestamp	TIMESTAMP_NTZ(9)	Block timestamp of this trade.
block_number	NUMBER(38,0)	Block number of this trade.
block_hash	VARCHAR(66)	Block hash of this trade.
unique_id	VARCHAR(134217728)	Unique ID of each trade.
_created_at	TIMESTAMP_NTZ(9)	Timestamp of the entry creation.
_updated_at	TIMESTAMP_NTZ(9)	Timestamp of the entry update.
_changed_since_full_refresh	BOOLEAN	Whether the entry was recreated.

EVM DEX Aggregator Trades