🤿Data Streaming Node

Solana Data Streaming Node with Yellowstone gRPC Geyser plugin

Overview

Rather than directly running a node yourself, we provide you with access to the data stream, helping you monitor real-time activities on the Solana blockchain without the complexity of setting up and managing your own infrastructure.

We offer fast and reliable access to real-time data streaming via our Solana RPC node with Yellowstone gRPC Geyser Plugin ensuring efficient data transmission with minimal latency.

This service is designed for users who need a truly quick and continuous access to Solana blockchain data for for on-chain analytics and network monitoring at an affordable price!

Key features

• Server location: New York (149.28.44.187:20000 ) and Amsterdam (62.197.45.101:10001 )

• No restrictions on the volume of data you can receive.

• 98-99% uptime, ensuring consistent access to real-time data.

• Amsterdam - Geyser and full RPC; New York - Geyser and RPC (only as an exception)

Price

$200 per month

How to Access ?

1. Reach us out https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog.

2. Provide Your IP Address: Once we receive your request, provide your IP address so we can add it to our whitelist.

3. Start Streaming!

What is Yellowstone geyser?

Geyser is a high-performance plugin for Solana that facilitates real-time blockchain data streaming. It provides efficient access to crucial blockchain data, including transaction details, account states, block information, and more. The plugin is designed to support developers and users by offering low-latency, high-throughput data streams, which are essential for in-depth on-chain analysis, monitoring, and application development.

Sample Code using Yellowstone Geyser

Typescript

import Yellowstone, { CommitmentLevel } from '@triton-one/yellowstone-grpc';
import { PublicKey } from '@solana/web3.js';

const GEYSER_URL   = ''; // <-- See above for the region NewYork / Amsterdam
const AUTH_TOKEN   = ''; // <-- Please reach out https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog
const WATCHED_PDA  = '3QMfsPS1P8sSWpqGNMGUfo2FDvoHoY7iZNwBoHSYm4wN';

async function main() {
  const client = new Yellowstone(GEYSER_URL, AUTH_TOKEN, {
    'grpc.max_receive_message_length': 10 * 1024 * 1024, // 10 MB
  });
  const stream = await client.subscribe();
  console.log('🟢 Connected to Geyser');

  // Describe what we want: every confirmed (PROCESSED) txn that
  // includes WATCHED_PDA anywhere in the message-level account keys
  const request = {
    commitment: CommitmentLevel.PROCESSED,
    transactions: {
      my_filter: {
        vote: false,
        failed: false,
        accountInclude: [ ],          // no extra allow-list
        accountExclude: [ ],          // no deny-list
        accountRequired: [ WATCHED_PDA ],
      },
    },
    // Everything else can stay empty for this simple demo
    accounts: {}, slots: {}, entry: {}, blocks: {}, blocksMeta: {},
    accountsDataSlice: [], transactionsStatus: {},
  };

  // Tell the stream what we want
  stream.write(request);

  
    console.log(`🔎 Subscribed to transactions touching ${WATCHED_PDA}`);

  // Handle pushed events
  stream.on('data', (msg) => {
    console.log(`📜 got update`);
  });

  // Basic error / end handling
  stream.on('error', console.error);
  stream.on('end',   () => console.loeam ended'));

  // Close cleanly on Ctrl-C
  process.on('SIGINT', () => {
    console.log('Shutting down…');
    stream.end();
    process.exit(0);
  });
}

main().catch(err => { console.error(err); process.exit(1); });

Python

Generate proto files using grpcio

import grpc
import geyser_pb2
import geyser_pb2_grpc

channel = grpc.insecure_channel("62.197.45.101:11000")
service = geyser_pb2_grpc.GeyserStub(channel)

request = geyser_pb2.SubscribeRequest()
request.transactions["tTt"].failed = False
request.transactions["tTt"].vote = False
request.commitment = geyser_pb2.CommitmentLevel.PROCESSED

transactions_stream = service.Subscribe(iter([request]))
for t in transactions_stream:
    print(t)

Support & Inquiries

For trial access, technical support, or troubleshooting inquiries, please contact us via Telegram (@inventandchill) or email ([e-mail]) or https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog. We’re here to assist with any questions or issues you may encounter.