Skip to content

Configuración del canal de eventos ETL

Esta página del socio ofrece un ejemplo de configuración de una consulta de clics de correo electrónico que puedes usar como referencia para configurar tus propias consultas.

Puedes usar esta consulta de clics de correo electrónico para analizar las interacciones con correos electrónicos específicos en tus Campaigns y Canvas de Braze.

Configura esta consulta

Crea una base de datos para BRAZE y luego crea una base de datos si no existe ninguna para BRAZE_CURRENTS;:

1
2
3
4
5
6
7
8
9
10
11

use schema BRAZE_CURRENTS.public;

create or replace stage braze_currents.public.braze_data
url='s3://tl-braze/'
credentials = (AWS_KEY_ID = 'XXXXXXXXX' AWS_SECRET_KEY = 'YYYYYY' );

create file format braze_currents.public.currents_avro type = 'avro' compression = 'auto';

alter stage braze_currents.public.braze_data set file_format = braze_currents.public.currents_avro;

show stages;

Usa el siguiente comando para crear tu tabla:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

CREATE TABLE
  braze_currents.public.users_messages_email_click (
    id STRING,
    user_id STRING,
    external_user_id STRING,
    time INT,
    timezone STRING,
    campaign_id STRING,
    campaign_name STRING,
    message_variation_id STRING,
    canvas_id STRING,
    canvas_name STRING,
    canvas_variation_id STRING,
    canvas_step_id STRING,
    send_id STRING,
    dispatch_id STRING,
    email_address STRING,
    url STRING,
    sending_ip STRING,
    user_agent STRING
  );

Usa el siguiente comando para crear o reemplazar tu canalización:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

CREATE OR REPLACE PIPE
  pipe_users_messages_email_click
    auto_ingest=true AS

COPY INTO
  braze_currents.public.users_messages_email_click
  FROM
  (select
    $1:id::STRING,
    $1:user_id::STRING,
    $1:external_user_id::STRING,
    $1:time::INT,
    $1:timezone::STRING,
    $1:campaign_id::STRING,
    $1:campaign_name::STRING,
    $1:message_variation_id::STRING,
    $1:canvas_id::STRING,
    $1:canvas_name::STRING,
    $1:canvas_variation_id::STRING,
    $1:canvas_step_id::STRING,
    $1:send_id::STRING,
    $1:dispatch_id::STRING,
    $1:email_address::STRING,
    $1:url::STRING,
    $1:sending_ip::STRING,
    $1:user_agent::STRING

    FROM
    @braze_currents.public.braze_data/currents/dataexport.prod-03.S3.integration.YOUR_INTEGRATION_ID_HERE/event_type=users.messages.email.click/);

show pipes;

Haz más con este ejemplo de consulta

Copia el notification_channel de la salida del comando anterior y úsalo para configurar las notificaciones del contenedor de S3.

Sincroniza manualmente desde S3 a Snowflake para el siguiente nombre de canalización:

1
2
3

ALTER PIPE
  pipe_users_messages_email_click
  refresh ;

Comprueba el estado de la canalización, que mostrará cuándo se reenvió el mensaje desde S3 a Snowflake:

1
2
3
4

SELECT
  SYSTEM$PIPE_STATUS(
    'pipe_users_messages_email_click'
  )

Por último, muestra el historial de copias de la tabla seleccionando * desde:

1

table(braze_currents.information_schema.copy_history(table_name=>'users_messages_email_click', start_time=> dateadd(hours, -1, current_timestamp())));
New Stuff!