Polygon DEX Events

Introduction

This guide shows you how to stream real-time DEX activity from Polygon into your own database. You’ll tap into the most active decentralized exchanges on the network: Uniswap, Quickswap, Balancer V2, Sushi, and Curve. The template captures a range of onchain events including swaps, liquidity changes, and more. By the end, you’ll have a working pipeline that decodes relevant contract event logs and stores structured trade data for analysis or downstream use.

Prerequisites

You’ll need:

A Neighborhood API key. To get access, sign up at accounts.indexing.co or email [email protected]
curl or Postman
An active postgres database

What You’ll Build

A pipeline that:

Listens to the majority of Polygon DEX contracts and their events
Decodes them with the event metadata
Streams transformed data into a unified postgres table

Step 1: Add the Transformation Logic

We’ll want to decode and return all events + unified swaps for known DEXs. View the full code here

Step 2: Create the Transformation

curl https://app.indexing.co/dw/transformations/polygon_dex_events \
  -H 'Content-Type: application/json' \
  -H 'X-API-KEY: <your-api-key>' \
  -F code=@./polygon_dex_events.js

Step 3: Create the Database

create table dex_events (
  contract_address text,
  transaction_hash text,
  log_index int,
  method text,
  timestamp timestamptz,
  decoded jsonb,
  primary key (contract_address, transaction_hash, log_index)
);

create index on dex_events (contract_address, method,timestamp);

create table swaps (
  pool_address text,
  transaction_hash text,
  log_index int,
  timestamp timestamptz,
  token_in_address text,
  token_out_address text,
  token_in_amount numeric,
  token_out_amount numeric,
  from_address text,
  to_address text,
  primary key (pool_address, transaction_hash, log_index)
);

create index on swaps (token_in_address, timestamp);
create index on swaps (token_out_address, timestamp);

The contract_address and pool_address represents the swap pool for dex_events and swaps, respectively. The above provides a single, primary key index for each table, but you may find you want other indexes added based on scale and query patterns.

Step 4: Create the Pipeline

curl https://app.indexing.co/dw/pipelines \
  -H 'Content-Type: application/json' \
  -H 'X-API-KEY: <your-api-key>' \
  -d '{
    "name": "polygon_dex_events",
    "transformation": "polygon_dex_events",
    "networks": [
      "polygon"
    ],
    "enabled": true,
    "delivery": {
      "adapter": "POSTGRES",
      "connectionUri": "postgres://...",
      "tableMap": {
        "dex_events": ["contract_address", "transaction_hash", "log_index"],
        "swaps": ["pool_address", "transaction_hash", "log_index"]
      }
    }
  }'

Step 5: Test the Stream

Once live, your database should receive events like:

{
  "pool_address": "0x4e3288c9ca110bcc82bf38f09a7b425c095d92bf",
  "transaction_hash": "0xf087c159221c15b751979539d0db9c45b0e509c3f80cc988c9cebc51b7b69e40",
  "log_index": 504,
  "timestamp": "2025-07-16T23:21:42.000Z",
  "token_in_address": "0x2791bca1f2de4661ed88a30c99a7a9449aa84174",
  "token_in_amount": "2323",
  "token_out_address": "0x2791bca1f2de4661ed88a30c99a7a9449aa84174",
  "token_out_amount": "2323"
}

You can test this manually and end-to-end using:

curl 'https://app.indexing.co/dw/pipelines/polygon_dex_events/test/polygon/74046728' -H 'X-API-KEY: <your-api-key>' -X POST

Wrap-Up

You’ve now set up a real-time stream of Polygon DEX events using The Neighborhood. The data you’re receiving is contains events from the most used Polygon DEXs. In case you want to add new DEXs we encourage you to reach out to us or adjust the template. Need help or want to go further?

Reach out at indexing.co/contact
Or email us at [email protected]

Featured Walkthroughs

EVM

Data Delivery

Integrations

Tips & Tricks

Introduction

Prerequisites

What You’ll Build

Step 1: Add the Transformation Logic

Step 2: Create the Transformation

Step 3: Create the Database

Step 4: Create the Pipeline

Step 5: Test the Stream

Wrap-Up

​Introduction

​Prerequisites

​What You’ll Build

​Step 1: Add the Transformation Logic

​Step 2: Create the Transformation

​Step 3: Create the Database

​Step 4: Create the Pipeline

​Step 5: Test the Stream

​Wrap-Up

Introduction

Prerequisites

What You’ll Build

Step 1: Add the Transformation Logic

Step 2: Create the Transformation

Step 3: Create the Database

Step 4: Create the Pipeline

Step 5: Test the Stream

Wrap-Up