Bitquery Protobuf Kafka Package

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

▶️ Hyperliquid

from hyperliquid import hyperliquid_block_message_pb2

# One message per HyperCore block: trades, orders, funding, liquidations,
# TWAPs, book updates, oracle prices, leverage changes, and signed actions
msg = hyperliquid_block_message_pb2.HyperliquidCoreBlockMessage()
msg.ParseFromString(serialized)

for trade in msg.Trades:
    print(trade)

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

Hyperliquid (HyperCore)

hyperliquid_block_message_pb2.HyperliquidCoreBlockMessage — one message per HyperCore block, covering all market kinds (perp, HIP-3, spot, outcome) with fields Trades, Orders, Funding, Liquidations, Twaps, BookUpdates, Prices, LeverageChanges, and SignedActions
fills_pb2 — trade fills
order_statuses_pb2 — order status updates
twap_statuses_pb2 — TWAP order statuses
raw_book_diffs_pb2 — raw order book diffs
oracle_updates_pb2 — oracle price updates
core_writer_actions_pb2 — core writer actions
misc_events_pb2 — funding, liquidations, and other misc events
transactions_pb2 — consensus-stream transactions (leverage changes, signed actions)
hypercore_pb2, candles_pb2 — supporting HyperCore types and candles

Offchain

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

Metadata

Release files for bitquery-pb2-kafka-package 0.2.35

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for bitquery-pb2-kafka-package 0.2.35
File	Size	Uploaded	Provenance
bitquery_pb2_kafka_package-0.2.35.tar.gz	37.6 kB	Oct 19, 2026	Without provenance	Details

Built distribution (wheel)

Table of built distributions (wheels) for bitquery-pb2-kafka-package 0.2.35
File	Interpreter	ABI	Platform	Reset
bitquery_pb2_kafka_package-0.2.35-py3-none-any.whl 75.5 kB Oct 19, 2026 Without provenance	Python 3	none	any	Details

Total release size: 113.1 kB

Release files / bitquery_pb2_kafka_package-0.2.35.tar.gz

Download URL	bitquery_pb2_kafka_package-0.2.35.tar.gz
Size	37.6 kB
Tags	Source
SHA-256 checksum How to use checksums	`19e9f0ffd294b412445de09cbfb53284140e67ef8c43c1c13bceccc1616ebc52`
BLAKE2b-256 checksum How to use checksums	`f9b4ac6c30894f3149354ca2a75bfd00ce31cb1842adcc59f7ff83e5f655f2f7`
Upload date	Oct 19, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.10.20`

Release files / bitquery_pb2_kafka_package-0.2.35-py3-none-any.whl

Download URL	bitquery_pb2_kafka_package-0.2.35-py3-none-any.whl
Size	75.5 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`eba0b98ab62e5aa56913912d74e12f31d8b47c02667f841c9040a5242185ed90`
BLAKE2b-256 checksum How to use checksums	`5088a333204f029bef7938e1b567950639dcec1967305b2b304e0e85be602758`
Upload date	Oct 19, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.10.20`

Security for bitquery-pb2-kafka-package 0.2.35

Report project as malware

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

No provenance found

None of the files in this release were uploaded with provenance metadata.

A note on package security

PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.

To learn more about protecting yourself from malicious actors, visit our package security documentation.