Real-time block-aggregated swap data for Uniswap V3 pools on Ethereum mainnet.
The substream produces DexOutput
messages containing:
substreams run coinranking-uniswap-v3-v0.2.0.spkg map_uniswap_ticker_output \
--substreams-api-token="YOUR_TOKEN" \
--substreams-endpoint="mainnet.eth.streamingfast.io:443" \
-s 12345678 # Start from any block
0x
prefixvolume_24h_token0
and volume_24h_token1
fields from outputlib.rs
filesubstreams gui coinranking-uniswap-v3@v0.2.0 map_uniswap_ticker_output
This module will loop over block transactions and detect pools created events.
Once the pool created events have been detected, Pools
structs will be emitted out of the module.
Try with
substreams gui substreams.yaml map_pools_created -t +1000
substreams gui coinranking-uniswap-v3@v0.2.0 uniswap:uni_v0_2_9:map_pools_created
Chunky module which emits multiple types of Events
. Looping over every transaction to filter out Events
.
For some events, we have to loop over StorageChanges
to be able to fetch certain changes such as liquidity
increases and decreases.
For more information on what the Event
contains, check proto/uniswap/v1/uniswap.proto.
Try with
substreams gui substreams.yaml map_extract_data_types -t +1000
substreams gui coinranking-uniswap-v3@v0.2.0 uniswap:uni_v0_2_9:map_extract_data_types
This module stores the Pools emitted by the map_pools_created
module.
Dynamic data sources pattern for Uniswap v3 pools.
substreams gui coinranking-uniswap-v3@v0.2.0 uniswap:uni_v0_2_9:store_pools_created
message
Request
message
Response
message
BlockUndoSignal
message
BlockScopedData
message
SessionInit
message
InitialSnapshotComplete
message
InitialSnapshotData
message
MapModuleOutput
message
StoreModuleOutput
message
OutputDebugInfo
message
ModulesProgress
message
ProcessedBytes
message
Error
message
Job
message
Stage
message
ModuleStats
message
ExternalCallMetric
message
StoreDelta
message
BlockRange
message
EntityChanges
message
EntityChange
message
Value
message
Array
message
Field
message
FileDescriptorSet
message
FileDescriptorProto
message
DescriptorProto
message
ExtensionRangeOptions
message
FieldDescriptorProto
message
OneofDescriptorProto
message
EnumDescriptorProto
message
EnumValueDescriptorProto
message
ServiceDescriptorProto
message
MethodDescriptorProto
message
FileOptions
message
MessageOptions
message
FieldOptions
message
OneofOptions
message
EnumOptions
message
EnumValueOptions
message
ServiceOptions
message
MethodOptions
message
UninterpretedOption
message
SourceCodeInfo
message
GeneratedCodeInfo
message
Any
message
Timestamp
message
Modules
message
Binary
message
Module
message
Package
message
NetworkParams
message
PackageMetadata
message
ModuleMetadata
message
Clock
message
BlockRef
message
DeployRequest
message
Parameter
message
DeployResponse
message
UpdateRequest
message
UpdateResponse
message
InfoRequest
message
InfoResponse
message
SinkProgress
message
PackageInfo
message
ListRequest
message
ListResponse
message
DeploymentWithStatus
message
RemoveRequest
message
RemoveResponse
message
PauseRequest
message
PauseResponse
message
StopRequest
message
StopResponse
message
ResumeRequest
message
ResumeResponse
enum
DeploymentStatus
message
ERC20Tokens
message
ERC20Token
message
Liquidity
message
Pools
message
Pool
message
Events
message
SnapshotPositions
message
SnapshotPosition