name: celo-decoded-logs
apiVersion: 3
sources:
celo.decoded_logs:
dataset_name: celo.decoded_logs
type: dataset
version: 1.0.0
transforms:
celo_decoded_logs:
primary_key: id
sql: |-
SELECT
address,
event_signature,
event_params,
raw_log.block_number as block_number,
raw_log.block_hash as block_hash,
raw_log.log_index as log_index,
raw_log.transaction_hash as transaction_hash,
raw_log.transaction_index as transaction_index,
id
FROM celo.decoded_logs
description: Unnesting raw_log
sinks:
postgres_celo_decoded_logs:
type: postgres
table: celo_decoded_logs
schema: public
secret_name: YOUR_DATABASE_SECRET
description: 'Postgres sink for: celo_decoded_logs'
from: celo_decoded_logs
