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)

Project links

Key dates

PyPI data
Data sourced directly from PyPI's database.
  • Released:
Newer release available (0.2.33)

2 maintainers

PyPI data
Data sourced directly from PyPI's database.
Avatar for divyasshree from gravatar.com divyasshree Avatar for marketing_bitquery from gravatar.com marketing_bitquery

Credits

Author: Bitquery

License

MIT License

Requires

Python >=3.6

Classifiers

Report project as malware

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

bitquery_pb2_kafka_package-0.2.32.tar.gz (29.5 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

bitquery_pb2_kafka_package-0.2.32-py3-none-any.whl (58.2 kB view details)

Uploaded Python 3

File details

Details for the file bitquery_pb2_kafka_package-0.2.32.tar.gz.

File metadata

File hashes

Hashes for bitquery_pb2_kafka_package-0.2.32.tar.gz
Algorithm Hash digest
SHA256 188cc983cc5eaa5382dfc8e7060e2be639c654def5684f4ff3688d43010e39e6
MD5 e70d451afb973ad018ed141c6b4ec65f
BLAKE2b-256 40a05b207e542410b6c341ffbf4a74c0499905b860d80dc9c021cef5a30b5297

See more details on using hashes here.

File details

Details for the file bitquery_pb2_kafka_package-0.2.32-py3-none-any.whl.

File metadata

File hashes

Hashes for bitquery_pb2_kafka_package-0.2.32-py3-none-any.whl
Algorithm Hash digest
SHA256 34083405f0b7408f2e98ed19f2b92f4dec2c40e357ca6a86e324b4b3bcd2e6b1
MD5 b3507476605566586a71d50f2c1baf21
BLAKE2b-256 e0e9f39da2daaf134dde578266f59ca35f218a50065d91724c01de67d86b099f

See more details on using hashes here.

Release history Release notifications | RSS feed

0.2.33

2 files

This release

0.2.32 This release

2 files

0.2.31

2 files

0.2.30

2 files

0.2.29

2 files

0.2.28

2 files

0.2.27

2 files

0.2.26

2 files

0.2.25

2 files

0.2.24

2 files

0.2.23

2 files

0.2.22

2 files

0.2.21

2 files

0.2.20

2 files

0.2.19

2 files

0.2.17

2 files

0.2.15

2 files

0.2.13

2 files

0.2.11

2 files

0.2.10

2 files

0.2.9

2 files

0.2.8

2 files

0.2.7

2 files

0.2.6

2 files

0.2.5

2 files

0.2.4

2 files

0.2.3

2 files

0.2.2

2 files

0.2.1

2 files

0.2.0

2 files

0.1.9

2 files

0.1.8

2 files

0.1.6

2 files

0.1.5

2 files

0.1.4

2 files

0.1.3

2 files

0.1.2

2 files

0.1.1

2 files

0.1.0

2 files

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page