Solana Streams

Beta

The most powerful Solana
real-time data pipelines

Eliminate the need for complex ETL pipelines and constant polling on Solana. Streams provides a continuous, push-based data flow that simplifies your data ingestion process.

Create a free Stream

Live

Index Solana Transactions

Solana Mainnet

Filtered payload
Raw payload

Live

New Raydium Pools

Solana Mainnet

Filtered payload
Raw payload

Live

Monitor Accounts

Solana Mainnet

Filtered payload
Raw payload

Extract

Instant access to
streaming Solana data

Transform

Tools to turn raw data
into your data

function main(data) {

try {

var data = data.streamData;

const addresses = [

"O8gFLKB5MbQAFEhE0hjZ4a6BDPv4bcIr5RyWHzyHE6lf",

"qEXih0ktFgGMZ8QFvRkZJwHEwsBRuWkoejlDHvyDvsKJ",

"vy66nKHXLDkhpIE4Euz3uMLG5SWID8aFfY5XbgmSrl5z"

];

var addressSet = new Set(addresses.map(address => address.toLowerCase()));

var paddedAddressSet = new Set(addresses.map(address => '0x' + address.toLowerCase().slice(2).padStart(64, '0')));

var matchingTransactions = [];

var matchingReceipts = [];

data.block.transactions.forEach(transaction => {

let transactionMatches = (transaction.from && addressSet.has(transaction.from.toLowerCase())) ||

(transaction.to && addressSet.has(transaction.to.toLowerCase()));

if (transactionMatches) {

matchingTransactions.push(transaction);

}

});

data.receipts.forEach(receipt => {

let receiptMatches = receipt.logs && receipt.logs.some(log =>

log.topics && log.topics.length > 1 &&

(paddedAddressSet.has(log.topics[1]) || (log.topics.length > 2 && paddedAddressSet.has(log.topics[2])))

);

if (receiptMatches) {

matchingReceipts.push(receipt);

}

});

if (matchingTransactions.length === 0 && matchingReceipts.length === 0) {

return null;

}

return {

transactions: matchingTransactions,

receipts: matchingReceipts

};

} catch (e) {

return {error: e.message};

}

Raw payload

Shape

Needs transformation

Size

20.2MB

Filtered payload

Shape

Valid payload shape

Size

1.2MB

New!

Filter and Transform your data exactly how you want, so you get the data you need and pay for nothing more.

Learn more

New!

Key-Value Store lets you target and access dynamic lists and sets, updatable from anywhere natively within streams and API.

Learn more

	walletStore <List>

function main(data) {

var matchingTransactions = [];

function checkAddress(address) {

let result = qnContainsListItem("walletStore", address);

return result;

}

data.streamData.block.transactions.forEach(transaction => {

let transactionMatches = (transaction.from && checkAddress(transaction.from)) ||

(transaction.to && checkAddress(transaction.to));

if (transactionMatches) {

matchingTransactions.push(transaction);

}

});

return matchingTransactions;

}

Load

We focus on infrastructure,
so you can focus on innovation

PostgreSQL

Amazon S3

Webhook

Snowflake

Coming soon

Guaranteed delivery
to one of our many pre-built destinations

Use Functions to enrich, process, and run custom code on our scalable serverless platform, enabling workflow creation without additional services.

Learn more about Functions

Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

"The outstanding real-time performance helps us deliver the freshest analytics to our users – key to maintaining our competitive edge in the industry."

Nirmal

Head of Engineering

Scalable, serverless, simple.
See for yourself in seconds.

Create a free Stream

60% Cheaper

Experience substantial savings compared to conventional methods when handling the same load by using more efficient resource utilization.

7x Faster

Achieve faster backfill speeds over traditional backfilling techniques, significantly reducing the time required for data synchronization.

~80hrs Saved

Drastically reduce data engineering hours with automatic routing to your data warehouses, streamlining your workflows in seconds.

Solana Streams

Beta

The most powerful Solana
real-time data pipelines

Eliminate the need for complex ETL pipelines and constant polling on Solana. Streams provides a continuous, push-based data flow that simplifies your data ingestion process.

Create a free Stream

Live

Index Solana Transactions

Solana Mainnet

Filtered payload
Raw payload

Live

New Raydium Pools

Solana Mainnet

Filtered payload
Raw payload

Live

Monitor Accounts

Solana Mainnet

Filtered payload
Raw payload

Extract

Instant access to
streaming Solana data

Transform

Tools to turn raw data
into your data

function main(data) {

try {

var data = data.streamData;

const addresses = [

"O8gFLKB5MbQAFEhE0hjZ4a6BDPv4bcIr5RyWHzyHE6lf",

"qEXih0ktFgGMZ8QFvRkZJwHEwsBRuWkoejlDHvyDvsKJ",

"vy66nKHXLDkhpIE4Euz3uMLG5SWID8aFfY5XbgmSrl5z"

];

var addressSet = new Set(addresses.map(address => address.toLowerCase()));

var paddedAddressSet = new Set(addresses.map(address => '0x' + address.toLowerCase().slice(2).padStart(64, '0')));

var matchingTransactions = [];

var matchingReceipts = [];

data.block.transactions.forEach(transaction => {

let transactionMatches = (transaction.from && addressSet.has(transaction.from.toLowerCase())) ||

(transaction.to && addressSet.has(transaction.to.toLowerCase()));

if (transactionMatches) {

matchingTransactions.push(transaction);

}

});

data.receipts.forEach(receipt => {

let receiptMatches = receipt.logs && receipt.logs.some(log =>

log.topics && log.topics.length > 1 &&

(paddedAddressSet.has(log.topics[1]) || (log.topics.length > 2 && paddedAddressSet.has(log.topics[2])))

);

if (receiptMatches) {

matchingReceipts.push(receipt);

}

});

if (matchingTransactions.length === 0 && matchingReceipts.length === 0) {

return null;

}

return {

transactions: matchingTransactions,

receipts: matchingReceipts

};

} catch (e) {

return {error: e.message};

}

Raw payload

Shape

Needs transformation

Size

20.2MB

Filtered payload

Shape

Valid payload shape

Size

1.2MB

New!

Filter and Transform your data exactly how you want, so you get the data you need and pay for nothing more.

Learn more

New!

Key-Value Store lets you target and access dynamic lists and sets, updatable from anywhere natively within streams and API.

Learn more

	walletStore <List>

function main(data) {

var matchingTransactions = [];

function checkAddress(address) {

let result = qnContainsListItem("walletStore", address);

return result;

}

data.streamData.block.transactions.forEach(transaction => {

let transactionMatches = (transaction.from && checkAddress(transaction.from)) ||

(transaction.to && checkAddress(transaction.to));

if (transactionMatches) {

matchingTransactions.push(transaction);

}

});

return matchingTransactions;

}

Load

We focus on infrastructure,
so you can focus on innovation

PostgreSQL

Amazon S3

Webhook

Snowflake

Coming soon

Guaranteed delivery
to one of our many pre-built destinations

Use Functions to enrich, process, and run custom code on our scalable serverless platform, enabling workflow creation without additional services.

Learn more about Functions

Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
Filtered payload
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

"The outstanding real-time performance helps us deliver the freshest analytics to our users – key to maintaining our competitive edge in the industry."

Nirmal

Head of Engineering

Scalable, serverless, simple.
See for yourself in seconds.

Create a free Stream

60% Cheaper

Experience substantial savings compared to conventional methods when handling the same load by using more efficient resource utilization.

7x Faster

Achieve faster backfill speeds over traditional backfilling techniques, significantly reducing the time required for data synchronization.

~80hrs Saved

Drastically reduce data engineering hours with automatic routing to your data warehouses, streamlining your workflows in seconds.

The most powerful Solana real-time data pipelines

Index Solana Transactions

New Raydium Pools

Monitor Accounts

Instant access to streaming Solana data

Tools to turn raw data into your data

Filter and Transform your data exactly how you want, so you get the data you need and pay for nothing more.

Key-Value Store lets you target and access dynamic lists and sets, updatable from anywhere natively within streams and API.

We focus on infrastructure, so you can focus on innovation

Guaranteed delivery to one of our many pre-built destinations

Use Functions to enrich, process, and run custom code on our scalable serverless platform, enabling workflow creation without additional services.

"The outstanding real-time performance helps us deliver the freshest analytics to our users – key to maintaining our competitive edge in the industry."

Scalable, serverless, simple. See for yourself in seconds.

60% Cheaper

7x Faster

~80hrs Saved

The most powerful Solana real-time data pipelines

Index Solana Transactions

New Raydium Pools

Monitor Accounts

Instant access to streaming Solana data

Tools to turn raw data into your data

Filter and Transform your data exactly how you want, so you get the data you need and pay for nothing more.

Key-Value Store lets you target and access dynamic lists and sets, updatable from anywhere natively within streams and API.

We focus on infrastructure, so you can focus on innovation

Guaranteed delivery to one of our many pre-built destinations

Use Functions to enrich, process, and run custom code on our scalable serverless platform, enabling workflow creation without additional services.

"The outstanding real-time performance helps us deliver the freshest analytics to our users – key to maintaining our competitive edge in the industry."

Scalable, serverless, simple. See for yourself in seconds.

60% Cheaper

7x Faster

~80hrs Saved

The most powerful Solana
real-time data pipelines

Instant access to
streaming Solana data

Tools to turn raw data
into your data

We focus on infrastructure,
so you can focus on innovation

Guaranteed delivery
to one of our many pre-built destinations

Scalable, serverless, simple.
See for yourself in seconds.

The most powerful Solana
real-time data pipelines

Instant access to
streaming Solana data

Tools to turn raw data
into your data

We focus on infrastructure,
so you can focus on innovation

Guaranteed delivery
to one of our many pre-built destinations

Scalable, serverless, simple.
See for yourself in seconds.