Skip to main content

Table Details

PropertyValue
Table Namecelo.dex.aggregator_trades
Table StatusProduction-Ready
Unique Keyblock_timestamp, unique_id
Clustering Key(s)block_timestamp::date
Search Optimizationtransaction_hash, project, transaction_from_address

Table Columns

Column NameData TypeDescription
integratorVARCHAR(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_tagVARCHAR(134217728)Contract address, event log field or other relevant field that is used to indicate the frontend integrator
projectVARCHAR(134217728)Name of the project. Includes dodo, paraswap, zeroex, cow_protocol, kyberswap_aggregator, tokenlon, openocean.
protocolVARCHAR(134217728)DEX protocol or project contract which executed the aggregator trade.
event_nameVARCHAR(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_addressVARCHAR(42)The name of the event (or the function call) for this trade.
liquidity_pool_addressVARCHAR(42)The contract address of the aggregator.
sender_addressVARCHAR(42)Address of the sender of the swap event log, which can be the Router.
to_addressVARCHAR(42)Address of the recipient of the swap event.
token_sold_addressVARCHAR(42)Address of the token sold.
token_sold_nameVARCHAR(134217728)Name of the token sold.
token_sold_symbolVARCHAR(134217728)Symbol of the token sold.
token_sold_amount_raw_strVARCHAR(134217728)Amount of token sold (not divided by the number of decimals) in string.
token_sold_amount_rawFLOATAmount of token sold (not divided by the number of decimals).
token_sold_amount_strVARCHAR(134217728)token_sold_amount_raw divided by the number of decimals of the token in string.
token_sold_amountFLOATtoken_sold_amount_raw divided by the number of decimals of the token.
usd_sold_amountFLOATUSD value of tokens sold.
token_bought_addressVARCHAR(42)Token address of the token bought, i.e. the asset acquired from the trade.
token_bought_nameVARCHAR(134217728)Name of the token bought.
token_bought_symbolVARCHAR(134217728)Symbol of the token bought.
token_bought_amount_raw_strVARCHAR(134217728)Amount of token bought (not divided by the number of decimals) in string.
token_bought_amount_rawFLOATAmount of token bought (not divided by the number of decimals).
token_bought_amount_strVARCHAR(134217728)token_bought_amount_raw divided by the number of decimals of the token in string.
token_bought_amountFLOATtoken_bought_amount_raw divided by the number of decimals of the token.
usd_bought_amountFLOATUSD value of tokens bought.
usd_amountFLOATUSD value of the swap. Note that this preferentially selects the price and value of the more reputable token.
extra_fieldsVARIANTThis field contains all the extra columns emitted from the event/function call that were not part of the convetional DEX trades columns.
transaction_from_addressVARCHAR(42)The address of the sending party of this transaction.
transaction_to_addressVARCHAR(42)The address of the receiving party of this transaction (could be a contract address).
transaction_hashVARCHAR(66)Transaction hash of this trade.
transaction_indexNUMBER(38,0)Transaction index of this trade in the block.
transaction_feesFLOATFees paid at the transaction level.
transaction_fees_usdFLOATFees paid in USD.
fee_detailsVARIANTAdditional fee details of the transaction, including max priority fee, gas price and gas used for the transaction.
selectorVARCHAR(134217728)The 4-byte function selector of the transaction calldata.
log_indexNUMBER(38,0)Log index of this trade.
block_timestampTIMESTAMP_NTZ(9)Block timestamp of this trade.
block_numberNUMBER(38,0)Block number of this trade.
block_hashVARCHAR(66)Block hash of this trade.
unique_idVARCHAR(134217728)Unique ID of each trade.
_created_atTIMESTAMP_NTZ(9)Timestamp of the entry creation.
_updated_atTIMESTAMP_NTZ(9)Timestamp of the entry update.
_changed_since_full_refreshBOOLEANWhether the entry was recreated.