Small utility to stream past and/or current Algorand node JSON blocks to Redis or stdout. Blocks and TXn can be filtered and transformed and redirected using REGO - an Open Policy Agent language.
We are here to help your Algorand node shine! Go to https://algonode.cloud for more.
go get github.com/algonode/algostreamer
config.jsonc
{
// archival or catchup Algorand node config
// setup serveral nodes to fetch from the fastest one or failover
"algod": {
"queue": 100, // buffer up to this number of blocks when processing history
"nodes": [
{
"id": "private-node",
"address": "http://localhost:8180",
"token": "..."
},
{
"id": "public-node",
"address": "https://mainnet-api.algonode.cloud",
}
]
},
"sinks": {
// redis server config
"redis": {
"addr": "localhost:6379",
"user": "",
"pass": "",
"db": 0
},
},
}
- You can find your token in node/data/algo.token
- You can find your address in node/data/alogo.net
Start streaming from the current block
./algostreamer -f config.jsonc -s 2>error.log
Start streming from the block no 18000000 and then continue with current blocks
./algostreamer -r 18000000 -f config.jsonc -s 2>error.log
Copyright (C) 2022 AlgoNode Org.
algostreamer is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
if you like what we do feel free to support us by sending some microAlgos to
AlgoNode wallet: ALGONODEIBJTET5OSEAXIHDSIEG7C2DOFB2WDYLRZTXN3NXVJ3NJD26L4E