mirror of
https://github.com/FlipsideCrypto/external-models.git
synced 2026-02-06 13:17:03 +00:00
55 lines
1.2 KiB
SQL
55 lines
1.2 KiB
SQL
-- depends_on: {{ ref('bronze__oklink') }}
|
|
{{ config(
|
|
materialized = 'incremental',
|
|
unique_key = ['as_of_date', 'blockchain'],
|
|
tags = ['oklink'],
|
|
enabled = false
|
|
) }}
|
|
|
|
WITH source AS (
|
|
|
|
SELECT
|
|
date_day :: DATE AS as_of_date,
|
|
blockchain,
|
|
TRY_CAST(
|
|
DATA :data [0] :totalAddresses :: STRING AS INT
|
|
) AS total_addresses,
|
|
_inserted_timestamp
|
|
FROM
|
|
|
|
{% if is_incremental() %}
|
|
{{ ref("bronze__oklink") }}
|
|
{% else %}
|
|
{{ ref("bronze__oklink_FR") }}
|
|
{% endif %}
|
|
WHERE
|
|
metric = 'address'
|
|
AND total_addresses IS NOT NULL
|
|
|
|
{% if is_incremental() %}
|
|
AND _inserted_timestamp > (
|
|
SELECT
|
|
MAX(_inserted_timestamp)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
{% endif %}
|
|
)
|
|
SELECT
|
|
blockchain,
|
|
'tam' AS metric,
|
|
'The reported number of total_addresses as of the as_of_date' AS description,
|
|
as_of_date,
|
|
total_addresses,
|
|
_inserted_timestamp,
|
|
{{ dbt_utils.generate_surrogate_key(['blockchain', 'metric', 'as_of_date']) }} AS tam_id,
|
|
SYSDATE() AS inserted_timestamp,
|
|
SYSDATE() AS modified_timestamp
|
|
FROM
|
|
source qualify ROW_NUMBER() over (
|
|
PARTITION BY blockchain,
|
|
as_of_date
|
|
ORDER BY
|
|
_inserted_timestamp DESC nulls last
|
|
) = 1
|