How to Subscribe to Real-Time Data Stream using Bitquery API and Python GraphQL Client

GraphQL Tutorials
1

Step 1: Import required libraries

from python_graphql_client import GraphqlClient
import asyncio

This code block imports the GraphqlClient library and asyncio for asynchronous operations.

Step 2: Set up the OAuth token

auth_token = "Bearer YOUR_ACCESS_TOKEN"

Set up the OAuth token. Replace YOUR_ACCESS_TOKEN with your actual access token.

Step 3: Set up the GraphQL client

ws = GraphqlClient(endpoint="wss://streaming.bitquery.io/graphql", headers={"Authorization": auth_token})

This code sets up a GraphqlClient instance with the Bitquery WebSocket endpoint and OAuth authorization header.

Step 4: Define the subscription callback function

def callback(response):
    print("got new OHLC data:")
    print(response)

This function is called every time new data is received from the WebSocket stream. The function prints the response.

Step 5: Define the GraphQL subscription query

query = """
 subscription {
    EVM(network: bsc) {
      Transfers {
        Block {
          Number
          Hash
        }
        Transfer {
          Currency {
            Symbol
            Name
          }
          Amount
        }
      }
    }
  }
"""

This code block defines the GraphQL subscription query, which is sent to the Bitquery API to subscribe to the Binance Smart Chain network’s Transfer events.

Step 6: Make an asynchronous subscription request

asyncio.run(ws.subscribe(query=query, handle=callback))

This code block makes an asynchronous subscription request to the Bitquery API with the defined subscription query and the handle parameter set to callback. The handle parameter specifies the function that should be called when new data is received.

Output on Terminal

Final Code

import asyncio
from python_graphql_client import GraphqlClient

auth_token = "Bearer YOUR_ACCESS_TOKEN"
ws = GraphqlClient(endpoint="wss://streaming.bitquery.io/graphql", headers={"Authorization": auth_token})

def callback(response):
    print("got new OHLC data:")
    print(response)

async def subscribe_to_transfers():
    query = """
    subscription {
        EVM(network: bsc) {
            Transfers {
                Block {
                    Number
                    Hash
                }
                Transfer {
                    Currency {
                        Symbol
                        Name
                    }
                    Amount
                }
            }
        }
    }
    """
    await ws.subscribe(query=query, handle=callback)

asyncio.run(subscribe_to_transfers())

This code uses OAuth for authentication by setting the authorization header with a Bearer token. Make sure to replace YOUR_ACCESS_TOKEN with your actual access token.

2 Likes
2

how i get all tokens data

below is my query and i want to get all data in python code can you please help me

subscription MyQuery {
Solana {
DEXTradeByTokens(
where: {Trade: {Currency: {MintAddress: {is: “3B5wuUrMEi5yATD7on46hKfej3pfmd7t1RKgrsN3pump”}}, Side: {Currency: {MintAddress: {is: “So11111111111111111111111111111111111111112”}}}, Dex: {ProgramAddress: {is: “675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8”}}}, Transaction: {Result: {Success: true}}}
) {
Block {
Time
}
Trade {
Currency {
Name
Symbol
}
Amount
PriceAgainstSideCurrency: Price
PriceInUSD
Side {
Currency {
Name
Symbol
}
Amount
Type
}
}
Transaction {
Maker: Signer
Signature
}
}
}
}

3

Check this code sample please @sumittale

4

i have one problem when i used the below code in my vscode then the code not giving me the correct data and when i run the query on bitquery ide then the code giving me the right data
why this is happening can you please help me.

import asyncio
from python_graphql_client import GraphqlClient
import time

auth_token = “Bearer ory_at_ejrB_FthB0Q35uZfO–6P8LXpRPjLKKYSW04wNyY6iA.HYMJAp9bSjFhB1KAgaPn3PazCbiSCCA_cwb5bBu2GmA”
ws = GraphqlClient(endpoint=“wss://streaming.bitquery.io/eap”, headers={“Authorization”: auth_token})

def callback(response):
print(“got new OHLC data:”)
print(response)
time.sleep(20)

async def subscribe_to_transfers():
query = “”"
subscription MyQuery {
Solana {
DEXTradeByTokens(
where: {Trade: {Currency: {MintAddress: {is: “B6DuEXoYuzqYTTscrGUGDCK1t9tGkH7Ud1yQq65AC6A8”}}, Side: {Currency: {MintAddress: {is: “So11111111111111111111111111111111111111112”}}}, Dex: {ProgramAddress: {is: “675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8”}}}, Transaction: {Result: {Success: true}}}
) {
Block {
Time
}
Trade {
Currency {
Name
Symbol
}
Amount
PriceAgainstSideCurrency: Price
PriceInUSD
Side {
Currency {
Name
Symbol
}
Amount
Type
}
}
Transaction {
Maker: Signer
Signature
}
}
}
}
“”"
await ws.subscribe(query=query, handle=callback)

asyncio.run(subscribe_to_transfers())

5

i have one problem when i used the below code in my vscode then the code not giving me the correct data and when i run the query on bitquery ide then the code giving me the right data
why this is happening can you please help me.

import asyncio
from python_graphql_client import GraphqlClient
import time

auth_token = “Bearer ory_at_ejrB_FthB0Q35uZfO–6P8LXpRPjLKKYSW04wNyY6iA.HYMJAp9bSjFhB1KAgaPn3PazCbiSCCA_cwb5bBu2GmA”
ws = GraphqlClient(endpoint=“wss://streaming.bitquery.io/eap”, headers={“Authorization”: auth_token})

def callback(response):
print(“got new OHLC data:”)
print(response)
time.sleep(20)

async def subscribe_to_transfers():
query = “”"
subscription MyQuery {
Solana {
DEXTradeByTokens(
where: {Trade: {Currency: {MintAddress: {is: “B6DuEXoYuzqYTTscrGUGDCK1t9tGkH7Ud1yQq65AC6A8”}}, Side: {Currency: {MintAddress: {is: “So11111111111111111111111111111111111111112”}}}, Dex: {ProgramAddress: {is: “675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8”}}}, Transaction: {Result: {Success: true}}}
) {
Block {
Time
}
Trade {
Currency {
Name
Symbol
}
Amount
PriceAgainstSideCurrency: Price
PriceInUSD
Side {
Currency {
Name
Symbol
}
Amount
Type
}
}
Transaction {
Maker: Signer
Signature
}
}
}
}
“”"
await ws.subscribe(query=query, handle=callback)

asyncio.run(subscribe_to_transfers())

6

@sumittale please reset your token, since it is exposed in this post. Regarding the data, can you share an example of the error you are talking about?