flip/sui-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/sui-models.git synced 2026-02-06 11:06:56 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

sizing

Browse Source
This commit is contained in:
Eric Laurello 2025-07-18 08:39:31 -04:00
parent 6104d957d6
commit 51058491ca
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
models/streamline/core/realtime/streamline__transactions_realtime.sql
View File

@ -4,9 +4,9 @@
func = 'streamline.udf_bulk_rest_api_v2',
target = "{{this.schema}}.{{this.identifier}}",
params ={ "external_table" :"transactions",
"sql_limit" :"600000",
"producer_batch_size" :"600000",
"worker_batch_size" :"6000",
"sql_limit" :"90000",
"producer_batch_size" :"90000",
"worker_batch_size" :"3000",
"async_concurrent_requests" :"5",
"sql_source" :"{{this.identifier}}",
'exploded_key': '["result"]',
@ -42,7 +42,7 @@ txs AS (
FROM
last_3_days
) #}
) {# ,
),
tx_grouped AS (
SELECT
checkpoint_number,
@ -60,10 +60,10 @@ tx_grouped AS (
checkpoint_number,
block_timestamp,
grp
) #}
)
SELECT
checkpoint_number,
1 AS tx_count_in_request,
tx_count_in_request,
to_char(
block_timestamp,
'YYYY_MM_DD_HH_MI_SS_FF3'
@ -85,10 +85,10 @@ SELECT
'id',
checkpoint_number,
'method',
'sui_getTransactionBlock',
'sui_multiGetTransactionBlocks',
'params',
ARRAY_CONSTRUCT(
tx_digest,
tx_param,
OBJECT_CONSTRUCT(
'showInput',
TRUE,
@ -110,8 +110,4 @@ SELECT
'Vault/prod/sui/quicknode/mainnet'
) AS request
FROM
txs
ORDER BY
block_timestamp DESC
LIMIT
600000
tx_grouped