Bitquery Protobuf Kafka Package

A Python library containing pb2 files to simplify parsing blockchain data (Solana, EVM, Tron, TON, UTXO) and market/trading data from Bitquery Kafka Streams using Protobuf messages.

Read more on Bitquery onchain data streams here

Installation

Install easily via pip:

pip install bitquery-pb2-kafka-package

Usage

You can import and use the protobuf-generated Python classes like this:

▶️ Price Index / Market

Read about the new price index stream here

from market import price_index_pb2, trades_pb2, marketdata_pb2

# Price index updates (currency, token, and pair price updates)
price_feed = price_index_pb2.PriceIndexMessage()

# Trades stream
trades_msg = trades_pb2.TradesMessage()

▶️ Solana

from solana import block_message_pb2

# Create a Solana BlockMessage instance
block_message = block_message_pb2.BlockMessage()

# Set fields
block_message.field_name = "value"

# Serialize to bytes
serialized = block_message.SerializeToString()

# Deserialize from bytes
msg = block_message_pb2.BlockMessage()
msg.ParseFromString(serialized)

print(msg)

▶️ EVM

from evm import block_message_pb2

# Create an EVM BlockMessage instance
evm_block = block_message_pb2.BlockMessage()

# Set fields
evm_block.field_name = "value"

# Serialize and Deserialize
data = evm_block.SerializeToString()
decoded = block_message_pb2.BlockMessage()
decoded.ParseFromString(data)

print(decoded)

▶️ Tron

from tron import block_message_pb2

# Create a Tron BlockMessage instance
tron_block = block_message_pb2.BlockMessage()

# Set fields
tron_block.field_name = "value"

# Serialize and Deserialize
data = tron_block.SerializeToString()
decoded = block_message_pb2.BlockMessage()
decoded.ParseFromString(data)

print(decoded)

Available Protobuf Messages

Price Index / Market

• price_index_pb2.PriceIndexMessage — top-level message with CurrencyUpdates, TokenUpdates, and PairUpdates
• price_index_pb2.PairUpdate — pair-level price update with market, currency, token, and price data
• price_index_pb2.CurrencyUpdate — currency-level price update
• price_index_pb2.TokenUpdate — token-level price update with ranking
• trades_pb2.TradesMessage — stream of trades with pair, amounts, price, trader, and transaction info
• trades_pb2.Trade — individual trade with Side (Buy/Sell), Price, PriceInUsd, and amounts
• marketdata_pb2.MarketdataMessage — currency price buckets from external sources (e.g. CryptoRank)

Solana

• block_message_pb2.BlockMessage
• dex_block_message_pb2.DexBlockMessage
• ohlc_message_pb2.OhlcMessage
• parsed_idl_block_message_pb2.ParsedIdlBlockMessage
• token_block_message_pb2.TokenBlockMessage
• perpetual_block_message_pb2.PerpetualBlockMessage — perpetual DEX activity (ParsedPerpetualTransaction, PerpetualAsset, PerpetualAmount)
• prediction_market_block_message_pb2.PredictionMarketBlockMessage — prediction market activity (ParsedPredictionTransaction, OutcomeTrade, OutcomeSettlement)
• solana.corecast — CoreCast gRPC stream definitions (corecast_pb2, request_pb2, stream_message_pb2)

EVM

• block_message_pb2.BlockMessage
• dex_block_message_pb2.DexBlockMessage
• parsed_abi_block_message_pb2.ParsedAbiBlockMessage
• token_block_message_pb2.TokenBlockMessage
• dex_pool_block_message_pb2.DexPoolBlockMessage
• prediction_market_block_message_pb2.PredictionMarketBlockMessage

Tron

• block_message_pb2.BlockMessage
• dex_block_message_pb2.DexBlockMessage
• parsed_abi_block_message_pb2.ParsedAbiBlockMessage
• token_block_message_pb2.TokenBlockMessage

TON

• block_message_pb2.BlockMessage
• dex_block_message_pb2.DexBlockMessage
• event_message_pb2.EventMessage
• token_block_message_pb2.TokenBlockMessage
• trace_message_pb2 — transaction trace messages

UTXO (Bitcoin-like chains)

• block_message_pb2.BlockMessage
• parsed_block_message_pb2.ParsedBlockMessage

Offchain

• entities_pb2 — offchain entity definitions (addresses, chains, groups)