CELO API · GraphQL · Kafka · gRPC · Cloud export

The Celo data API for mobile-first money.

You shouldn't have to run a Celo node, babysit an archive node or stitch together raw JSON-RPC just to answer a simple question. On Enterprise, we've already indexed Uniswap trades, token transfers, contract calls, events and the mempool are one query — or one live stream — away.

Trusted on Celo byNansen logo0x logo3Commas logoLukka logo
EVM.DEXTradesReal-time & historical swaps across every Celo DEX.Docs
dex_trades.graphqlCopy
subscription {
  EVM(network: celo_mainnet) {
    DEXTrades(
      where: {Trade: {Dex:
        {ProtocolName: {is: "uniswap_v3"}}}}
    ) {
      Trade {
        Buy { Price Amount
          Currency { Symbol } }
        Dex { ProtocolName }
      }
    }
  }
}
responseSTREAMING
Pair / DEXSidePriceAmount
200 · gRPC · 88msstreaming.bitquery.io
01
Forget the RPC

JSON-RPC was never meant to answer the questions you actually have.

Ask "what did this wallet ever do?" and raw Celo hands you an archive node, a pile of ABIs to decode by hand and thousands of chained eth_getLogscalls. We've already done that work, so you can skip straight to the answer.

What you're doing
Raw Celo JSON-RPC
Bitquery Celo API
One wallet's full token & trade history
Thousands of eth_getLogs calls
A single GraphQL query
Reading Uniswap / Curve trades
You decode every event log
Decoded for every protocol
ERC-20, 721 & 1155 in one place
Three ABIs to parse yourself
One unified token schema
Mempool & pending transactions
Run your own node & filters
Streamed, sub-second
Historical depth
2TB+ archive node to sync
Complete history on Enterprise
Infrastructure to run
Celo, archive, reorg handling
None — fully managed
02
Delivery channels

Four ways to get Celo data — one schema underneath.

Write your query once in GraphQL and the same fields come back over GraphQL streams, Kafka, gRPC or a bulk cloud export. Nothing to re-model and no second pipeline to maintain — just pick the channel that matches how fast and how much you need.

03
DEX & protocol coverage

Every major Celo venue, decoded into one feed.

One DEXTrades query covers 100+ Celo DEXs. Filter by token, pair, pool, wallet or protocol, then roll it up however you need — OHLCV candles, liquidity events, slippage, pool reserves, top traders or volume.

VenueTypeWhat you get
Uniswap logoUniswapV2 · V3 · V4Swaps, pools, hooks, OHLCV, LP events
Curve logoCurveStableSwapStable & crypto pool trades, fees
SushiSwap logoSushiSwapAMMSwaps, pairs, liquidity events
Balancer logoBalancerWeighted poolsMulti-asset swaps & joins / exits
1inch logo1inchAggregatorRouted swaps across every market
PancakeSwap logoPancakeSwapAMM (ETH)V2 / V3 swaps on Celo mainnet
+ Maker, Bancor, Fraxswap & every new protocol we add
04
Celo datasets

Every Celo dataset, one GraphQL endpoint.

From ERC-20 transfers to the mempool, it's all behind a single endpoint — no node, no archive sync, no indexer to build. Every dataset is available as complete history on Enterprise and streams live over WebSocket or gRPC (fixed-cost Kafka on Enterprise) whenever you need it real time.

Tokens

Celo Token Transfers API

Every ERC-20, ERC-721 & ERC-1155 transfer with historical USD value, volumes and inflow / outflow per address.

Read the docs
DeFi

Celo DEX Trades API

Swaps across Uniswap V2/V3/V4, Curve, Sushi & 100+ DEXs with OHLCV candles, pairs, pools and per-wallet history.

Read the docs
NFT

Celo NFT API

Mints, sales, bids, ownership, holder distribution and metadata across OpenSea, Blur, LooksRare & more.

Read the docs
Wallets

Celo Balance API

Real-time & historical native CELO and token balances for any wallet, with USD portfolio value for trackers and tax tools.

Read the docs
Tokens

Celo Token Holders API

Top holders, balance distribution and decentralization metrics — Gini and Nakamoto coefficients — for any ERC-20.

Read the docs
Compliance

Money Flow · Coinpath®

Trace inbound and outbound fund flows across Celo addresses for AML, forensics and investigation workflows.

Read the docs
Contracts

Smart Contract Trace API

Decoded smart-contract call traces with arguments, internal transactions and success status — parsed by ABI.

Read the docs
Contracts

Smart Contract Events API

Decoded event logs by ABI — query Transfer, Approval, Swap or any topic by contract, name or event signature.

Read the docs
Real-time

Celo Mempool API

Stream pending transactions before they land and simulate outcomes — for MEV monitoring and frontrun protection.

Read the docs
Network

Celo Transactions API

Transaction details, receipts, internal transactions, gas used and status — filter by sender, receiver or value.

Read the docs
Network

Celo Blocks API

Block headers, timestamps, base fees, gas usage and validator data for time-series analytics and explorers.

Read the docs
Network

Celo Gas & Fees API

EIP-1559 base and priority fees, gas usage patterns and cost analysis to power gas estimators and fee dashboards.

Read the docs
05
Build it this weekend

The Celo products people actually ship on us.

Each of these is just a filter on the same indexed data — subscribe over WebSocket or gRPC on self-service (fixed-cost Kafka on Enterprise) when you're building a bot, or hit GraphQL when you're building a dashboard.

gRPC · Kafka

Catch new Ubeswap pools first

Get pool-creation and hook events the second they land, filtered by token pair or fee tier. Be early to every new market without watching the chain yourself.

subscribe EVM.Events
  where: { Log: { Signature: { Name: "Initialize" } } }
Read the docs
GraphQL

Wallet PnL & portfolio

Pull a wallet's entire transfer and trade history with historical USD prices already attached, and work out realized PnL across every DEX it has touched.

EVM.Transfers
  where: { Transfer.Receiver: "<wallet>" }
Read the docs
GraphQL

Build OHLCV price charts

Turn raw DEX trades into clean candlesticks per pair and interval — the same kind of feed behind TradingView-style Celo charts.

DEXTradeByTokens {
  Trade: { close: PriceInUSD ... }
} # 1m / 5m / 1h
Read the docs

What teams say about our Celo data

"We did a thorough search of the market for the best onchain data. Bitquery came out on top — and now powers all live prices across Nansen. We don't think of them as a vendor. They're a partner."

A
Alexander Karsten
Nansen
2020→now
Complete history on Enterprise
<300ms
Kafka & gRPC stream latency
100+
Celo DEXs decoded into one feed
Also building on Celo dataNansen0x3CommasLukkaCoin Metrics

Pricing

Celo is available on Enterprise

Celo is not included in our 9-chain self-service plans (Personal, Pro, Scale). Enterprise delivers complete history, unlimited streams and bulk delivery across 40+ chains — including Celo.

Enterprise

Enterprise

Full history, unlimited streams and bulk delivery at a predictable flat platform fee — no metering surprises.

Custom platform fee

flat fee — modelled, not metered

◆ Committed envelope · S3 Parquet · Kafka · datashares
  • Complete history · 40+ chains full platform coverage
  • Unlimited WebSocket streaming no stream-min or GB limit
  • Custom points & rate limits
  • Kafka fixed-cost · S3 bulk export
  • Coinpath® money flow
  • SLA · SSO · dedicated support
Talk to sales →

Self-service covers 9 core chains

Personal ($49), Pro ($99) and Scale ($299) include real-time data on Solana, Ethereum, Tron, Base, Arbitrum, Optimism, BSC, Polygon and Robinhood. Need a smaller entry point on those chains?

See platform pricingCompare Personal, Pro, Scale & Enterprise side by side

Every paid self-service plan includes a 7-day free trial with full streaming — no card required.

FAQ

Celo data questions, answered.

How can I get Celo blockchain data with Bitquery?
You get both historical and real-time Celo data through our GraphQL APIs, WebSocket subscriptions, Kafka streams and cloud warehouses (AWS, Snowflake, BigQuery). This chain is available on Enterprise — talk to sales for a committed plan, then start pulling blocks, transactions, transfers, DEX trades, NFT events, contract calls and ENS records from a single endpoint right away.
How do I query Uniswap, SushiSwap and other Celo DEX trades?
One DEXTrades query covers Uniswap V2/V3/V4, SushiSwap, Curve, Balancer, 1inch, PancakeSwap and 50+ other DEXs. Filter by token address, pair, time range or trader wallet, then aggregate into OHLCV candles, top traders or volume per pool — whatever your chart or report needs.
Can I stream Celo data in real-time — mempool, new blocks, transfers?
Yes — over Kafka, WebSocket subscriptions and gRPC, all with sub-second latency. You can stream pending transactions (the mempool), new blocks, token transfers, DEX trades and contract events, which is exactly what you want for trading bots, alerts, MEV monitoring and live analytics.
Does Bitquery support ERC-20, ERC-721 and ERC-1155 tokens?
Yes. Every ERC-20, ERC-721 and ERC-1155 token on Celo is indexed with full transfer history, holder counts, balances and metadata — and it all sits behind the same GraphQL schema, so you don't juggle three different standards.
How do I get Celo wallet balances, transactions and PnL?
Point the Transfers, Trades and Balancesqueries at a wallet address and you'll get its full transaction history, current and historical token balances, ENS name and trading PnL across every DEX it has used.
Does Bitquery support smart-contract calls and decoded event logs?
Yes. We decode and index every smart-contract call and event log on Celo straight from the contract's ABI. You can query function calls (swap, mint, transferFrom) and emitted events (Transfer, Approval, Sync) by contract address, function name or event signature — no manual decoding on your side.

Celo is available on Enterprise.

Celo is not on Personal, Pro or Scale. Enterprise delivers complete history, unlimited streams and bulk delivery across 40+ chains — including Celo. Talk to us for a committed plan.

Enterprise · Complete history · Custom committed pricing
40+ chains · one platform

Explore every blockchain Bitquery supports

Browse the full chain directory and coverage matrix — the same GraphQL schema, real-time streams and cloud datasets across every network we index.