add 2 new tasks for collecting chain activity every day and hour
This commit is contained in:
parent
9d280f7d5f
commit
4fd5d73b65
|
@ -0,0 +1,39 @@
|
|||
import "date"
|
||||
|
||||
//stop = date.truncate(t: now(), unit: 1h)
|
||||
//start = date.truncate(t: -1h,unit: 1h)
|
||||
|
||||
|
||||
runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
|
||||
data = from(bucket: srcBucket)
|
||||
|> range(start: start,stop: stop)
|
||||
|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
|
||||
|> set(key: "_measurement", value: destMeasurement)
|
||||
|> group(columns: ["emitter_chain", "destination_chain", "app_id"])
|
||||
|
||||
notional = data
|
||||
|> sum(column: "_value")
|
||||
|> rename(columns: {_value: "notional"})
|
||||
|
||||
txs = data
|
||||
|> count(column: "_value")
|
||||
|> rename(columns: {_value: "txs"})
|
||||
|
||||
|
||||
return join(tables: {t1: notional, t2: txs}, on: ["emitter_chain","destination_chain","app_id"])
|
||||
|> set(key: "_time", value: string(v:start))
|
||||
|> to(bucket: destBucket)
|
||||
}
|
||||
|
||||
|
||||
bucketInfinite = "wormscan-mainnet-staging"
|
||||
destMeasurement = "chain_activity_1d"
|
||||
stop = date.truncate(t: now(),unit: 24h)
|
||||
start = date.sub(d: 1d, from: stop)
|
||||
|
||||
option task = {
|
||||
name: "calculate chain activity every day",
|
||||
every: 1d,
|
||||
}
|
||||
|
||||
runTask(start:start, stop: stop, srcBucket: bucketInfinite, destBucket: bucketInfinite, destMeasurement: destMeasurement)
|
|
@ -0,0 +1,37 @@
|
|||
import "date"
|
||||
|
||||
|
||||
runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
|
||||
data = from(bucket: srcBucket)
|
||||
|> range(start: start,stop: stop)
|
||||
|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
|
||||
|> set(key: "_measurement", value: destMeasurement)
|
||||
|> group(columns: ["emitter_chain", "destination_chain", "app_id"])
|
||||
|
||||
notional = data
|
||||
|> sum(column: "_value")
|
||||
|> rename(columns: {_value: "notional"})
|
||||
|
||||
txs = data
|
||||
|> count(column: "_value")
|
||||
|> rename(columns: {_value: "txs"})
|
||||
|
||||
|
||||
return join(tables: {t1: notional, t2: txs}, on: ["emitter_chain","destination_chain","app_id"])
|
||||
|> set(key: "_time", value: string(v:start))
|
||||
|> to(bucket: destBucket)
|
||||
}
|
||||
|
||||
|
||||
bucketInfinite = "wormscan-mainnet-staging"
|
||||
destMeasurement = "chain_activity_1h"
|
||||
|
||||
stop = date.truncate(t: now(),unit: 1h)
|
||||
start = date.sub(d: 1h, from: stop)
|
||||
|
||||
option task = {
|
||||
name: "calculate chain activity every hour",
|
||||
every: 1h,
|
||||
}
|
||||
|
||||
runTask(start:start, stop: stop, srcBucket: bucketInfinite, destBucket: bucketInfinite, destMeasurement: destMeasurement)
|
Loading…
Reference in New Issue