​
Introduction

In this guide, you’ll build a real-time pipeline to track lending and borrowing activity from Polygon money markets AAVE and Compound V3. By listening to core protocol contracts, you’ll capture events like deposits, borrows, repayments, and liquidations, then decode and stream them directly into your database. By the end, you’ll have a working pipeline that decodes relevant contracts event logs and stores structured trade data for analysis or downstream use.

​
Prerequisites

You’ll need:
  • A Neighborhood API key. To get access, email hello@indexing.co
  • curl or Postman
  • An active postgres database

​
What You’ll Build

A pipeline that:
  1. Listens to the majority of Polygon money market contracts and their events
  2. Decodes them with the event metadata
  3. Streams transformed data into a unified postgres table

​
Step 1: Create a Contract Filter

Then create the filter: These are the contract addresses we’ll want to listen to: 
0x794a61358D6845594F94dc1DB02A252b5b4814aD
0xF25212E676D1F7F89Cd72fFEe66158f541246445
0xaeB318360f27748Acb200CE616E389A6C9409a07

curl https://app.indexing.co/dw/filters/polygon_money_market_addresses \
  -H 'Content-Type: application/json' \
  -H 'X-API-KEY: <your-api-key>' \
  -d '{
    "values": [
      "0x794a61358D6845594F94dc1DB02A252b5b4814aD",
      "0xF25212E676D1F7F89Cd72fFEe66158f541246445",
      "0xaeB318360f27748Acb200CE616E389A6C9409a07"
    ]
  }'

​
Step 2: Add the Transformation Logic

We’ll want to decode and return a unified set of in and out flows for known markets. View the full code here

​
Step 3: Create the Transformation

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

​
Step 4: Create the Database

create table money_market_events (
  pool_address text,
  transaction_hash text,
  log_index int,
  method text,
  timestamp timestamptz,
  wallet_address text,
  token_address text,
  amount numeric,
  primary key (pool_address, transaction_hash, log_index)
);
create index on money_market_events (wallet_address, timestamp desc);
The pool_address represents the liquidity pool that the event is tied to and method can be used to identify specific events. The above provides a single, primary key index, but you may find you want other indexes added based on scale and query patterns.

​
Example Queries

Identifying USD volume by liquidity pool within the last hour: 
select
  pool_address,
  sum(amount) / pow(10, 6) as volume
from
  money_market_events
where
  token_address in (
    '0x2791bca1f2de4661ed88a30c99a7a9449aa84174', -- USDC
    '0xc2132d05d31c914a87c6611c10748aeb04b58e8f' -- USDT
  )
  and timestamp > now() - interval '1 hour'
group by pool_address
order by sum(amount) desc;

​
Step 5: 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_money_market_events",
    "transformation": "polygon_money_market_events",
    "filter": "polygon_money_market_addresses",
    "filterKeys": [
      "pool_address"
    ],
    "networks": [
      "polygon"
    ],
    "enabled": true,
    "delivery": {
      "adapter": "POSTGRES",
      "connectionUri": "postgres://...",
      "table": "money_market_events",
      "uniqueKeys": ["pool_address", "transaction_hash", "log_index"]
    }
  }'

​
Step 6: Test the Stream

Once live, your database should receive events like: 
{
  "pool_address": "0x794a61358d6845594f94dc1db02a252b5b4814ad",
  "transaction_hash": "0xcaefff01eec692ef13503959437dfac7e1aeee9ecaa5a5d7b640a5dda30cccc6",
  "log_index": 707,
  "timestamp": "2025-07-16T23:12:14.000Z",
  "wallet_address": "0xadeccaba96f86f2eb4fbe219be39a87db7534ddb",
  "token_address": null,
  "amount": "524130000"
}
You can test this manually and end-to-end using: 
curl 'https://app.indexing.co/dw/pipelines/polygon_money_market_events/test/polygon/74046461' -H 'X-API-KEY: <your-api-key>' -X POST

​
Wrap-Up

You’ve now set up a real-time stream of Polygon Money Market events using The Neighborhood. The data you’re receiving is contains events from the most used Polygon Money Markets, AAVE and Compound V3. 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?