From 2cac2f024e7f4d36eb198dacebc225ef40e84c9d Mon Sep 17 00:00:00 2001 From: mattromano Date: Mon, 11 Dec 2023 13:51:07 -0800 Subject: [PATCH] add api_udf --- .../api_udf/bronze_api__contract_abis.sql | 20 +++---------------- 1 file changed, 3 insertions(+), 17 deletions(-) diff --git a/models/bronze/api_udf/bronze_api__contract_abis.sql b/models/bronze/api_udf/bronze_api__contract_abis.sql index ca16617..a00bbbc 100644 --- a/models/bronze/api_udf/bronze_api__contract_abis.sql +++ b/models/bronze/api_udf/bronze_api__contract_abis.sql @@ -5,19 +5,8 @@ tags = ['curated'] ) }} -WITH api_keys AS ( +WITH base AS ( - SELECT - api_key - FROM - {{ source( - 'crosschain_silver', - 'apis_keys' - ) }} - WHERE - api_name = 'snowtrace' -), -base AS ( SELECT contract_address FROM @@ -51,16 +40,13 @@ row_nos AS ( ROW_NUMBER() over ( ORDER BY contract_address - ) AS row_no, - api_key + ) AS row_no FROM all_contracts - JOIN api_keys - ON 1 = 1 ), batched AS ({% for item in range(101) %} SELECT - rn.contract_address, ethereum.streamline.udf_api('GET', CONCAT('https://api.snowtrace.io/api?module=contract&action=getabi&address=', contract_address, '&apikey=', api_key),{ 'User-Agent': 'FlipsideStreamline' },{}) AS abi_data, SYSDATE() AS _inserted_timestamp + rn.contract_address, live.udf_api('GET', CONCAT('https://api.snowtrace.io/api?module=contract&action=getabi&address=', contract_address, '&apikey={avax_key}'),{ 'User-Agent': 'FlipsideStreamline' },{}, 'EXPLORER') AS abi_data, SYSDATE() AS _inserted_timestamp FROM row_nos rn WHERE