bitquery-pb2-kafka-package 0.2.27

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) 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

Read about the new price index stream here

from price_index import price_index_pb2

price_feed=price_index_pb2.PriceIndexMessage()

▶️ 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

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