subscribe_8.py

#!/usr/bin/python3

from python_graphql_client import GraphqlClient
from json import dumps
import asyncio

def prettyPrint(data):
        print(dumps(data, sort_keys=True, indent=2))

try:
    client = GraphqlClient(endpoint="ws://localhost:7000/v1/graphql")

    query = """
        subscription {
            queuedPool {
                from
                to
                nonce
                gas
                gasPrice
                queuedFor
                pendingFor
                pool
            }
        }
    """

    print('Listening for any new tx, entering/ leaving queued pool')

    asyncio.run(client.subscribe(query=query, handle=prettyPrint))

except Exception as e:
    print(e)
except KeyboardInterrupt:
    print('\nStopping')