Data streams reference

Pump Fun

Real-time gRPC stream for Pump Fun trades and token creation events on Solana.

The current service exposes four Pumpfun topics.

EventTopic
Token creationprod.rpc.solana.pumpfun.create
Tradeprod.rpc.solana.pumpfun.trade
Graduationprod.rpc.solana.pumpfun.graduate
Transaction metadataprod.rpc.solana.pumpfun.transaction

Subscribe to trades

grpcurl \  -H "x-api-key: YOUR_API_KEY" \  -import-path . \  -proto enhanced-streams.proto \  -d '{"topic":"prod.rpc.solana.pumpfun.trade","format":"JSON"}' \  stream-1.nln.clr3.org:443 \  nln.stream.v1.StreamService/Subscribe

Python

import grpcimport jsonimport enhanced_streams_pb2 as pbimport enhanced_streams_pb2_grpc as rpc channel = grpc.secure_channel(    "stream-1.nln.clr3.org:443",    grpc.ssl_channel_credentials(),)client = rpc.StreamServiceStub(channel) request = pb.SubscribeRequest(    topic="prod.rpc.solana.pumpfun.trade",    format=pb.JSON,) for message in client.Subscribe(    request,    metadata=[("x-api-key", "YOUR_API_KEY")],):    event = json.loads(message.payload)    print(message.partition, message.offset, event)

Do not use the old pumpFunTrades topic. The service returns NOT_FOUND.