bitquery-pb2-kafka-package 0.2.29

This package contains the pb2 files necessary to interact with Bitquery Kafka Protobuf messages

Bitquery Protobuf Kafka Package

A Python library containing pb2 files to simplify parsing blockchain data (Solana, EVM, Tron) 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

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