{{
config(
materialized="sink",
connector="kinesis",
data_format="PLAIN",
data_encode="JSON",
connector_parameters={
"primary_key": "pk,sk",
"stream": var("kinesis_sink")[target.profile_name]["stream"],
"aws.region": var("kinesis_sink")[target.profile_name]["region"],
"aws.credentials.role.arn": var("kinesis_sink")[target.profile_name]["role_arn"],
"aws.credentials.access_key_id": env_var('AWS_ACCESS_KEY_ID', ''),
"aws.credentials.secret_access_key": env_var("AWS_SECRET_ACCESS_KEY", ''),
},
format_parameters={
"force_append_only": true,
},
)
}}
-- do some wrangling here:
SELECT * FROM {{ ref("model1") }}