Saltar al contenido

Actividad de Inserción en Snowflake

Introducción

Una actividad de Inserción en Snowflake, utilizando su conexión de Snowflake, inserta datos de tabla (ya sea como un archivo CSV o directamente mapeados a columnas de una tabla) en Snowflake y está destinada a ser utilizada como un objetivo para consumir datos en una operación.

Crear una actividad de Inserción en Snowflake

Una instancia de una actividad de Inserción en Snowflake se crea a partir de una conexión de Snowflake utilizando su tipo de actividad Insert.

Para crear una instancia de una actividad, arrastra el tipo de actividad al lienzo de diseño o copia el tipo de actividad y pégalo en el lienzo de diseño. Para más detalles, consulta Crear una instancia de actividad o herramienta en Reutilización de componentes.

Una actividad de Inserción en Snowflake existente se puede editar desde estas ubicaciones:

Configurar una actividad de Inserción en Snowflake

Sigue estos pasos para configurar una actividad de Inserción en Snowflake:

Paso 1: Ingresar un nombre y seleccionar un objeto

En este paso, proporciona un nombre para la actividad y selecciona una tabla o vista (consulta la Descripción general de vistas de Snowflake). Cada elemento de la interfaz de usuario de este paso se describe a continuación.

Configuración de la actividad de inserción de Snowflake paso 1

  • Nombre: Ingresa un nombre para identificar la actividad. El nombre debe ser único para cada actividad de Inserción de Snowflake y no debe contener barras diagonales / ni dos puntos :.

  • Seleccionar un objeto: Esta sección muestra los objetos disponibles en el endpoint de Snowflake. Al reabrir una configuración de actividad existente, solo se muestra el objeto seleccionado en lugar de recargar toda la lista de objetos.

    • Objeto de Snowflake seleccionado: Después de seleccionar un objeto, se lista aquí.

    • Buscar: Ingresa el valor de cualquier columna en el cuadro de búsqueda para filtrar la lista de objetos. La búsqueda no distingue entre mayúsculas y minúsculas. Si los objetos ya se muestran dentro de la tabla, los resultados de la tabla se filtran en tiempo real con cada pulsación de tecla. Para recargar objetos desde el endpoint al buscar, ingresa criterios de búsqueda y luego actualiza, como se describe a continuación.

    • Actualizar: Haz clic en el ícono de actualizar o en la palabra Actualizar para recargar objetos desde el endpoint de Snowflake. Esto puede ser útil si se han agregado objetos a Snowflake. Esta acción actualiza todos los metadatos utilizados para construir la tabla de objetos mostrada en la configuración.

    • Seleccionar un objeto: Dentro de la tabla, haz clic en cualquier parte de una fila para seleccionar un objeto. Solo se puede seleccionar un objeto. La información disponible para cada objeto se obtiene del endpoint de Snowflake:

      • Nombre: El nombre de un objeto, ya sea una tabla o una vista.

      • Tipo: El tipo del objeto, ya sea una tabla o una vista.

    Consejo

    Si la tabla no se llena con los objetos disponibles, la conexión a Snowflake puede no haber sido exitosa. Asegúrate de estar conectado volviendo a abrir la conexión y volviendo a probar las credenciales.

  • Guardar y salir: Si está habilitado, haz clic para guardar la configuración de este paso y cerrar la configuración de la actividad.

  • Siguiente: Haz clic para almacenar temporalmente la configuración de este paso y continuar al siguiente paso. La configuración no se guardará hasta que hagas clic en el botón Finalizado en el último paso.

  • Descartar cambios: Después de realizar cambios, haz clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje te pedirá que confirmes que deseas descartar los cambios.

Paso 2: Seleccionar un enfoque

Se admiten diferentes enfoques para insertar datos en Snowflake. Elige entre SQL Insert o Stage File. Al usar el enfoque de Stage File, seleccionas entre los tipos de archivos de etapa Amazon S3 o Interno.

Enfoque de inserción SQL

Para este enfoque, las columnas de la tabla se mostrarán en el paso del esquema de datos que sigue, permitiendo que se mapeen en una transformación.

Configuración de la actividad de inserción de Snowflake paso 2 enfoque de inserción SQL

  • Enfoque: Usa el menú desplegable para seleccionar SQL Insert.

  • Atrás: Haz clic para regresar al paso anterior y almacenar temporalmente la configuración.

  • Siguiente: Haz clic para continuar al siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que hagas clic en el botón Finalizado en el último paso.

  • Descartar Cambios: Después de realizar cambios, haz clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje te pide que confirmes que deseas descartar los cambios.

Enfoque de Archivo de Etapa de Amazon S3

Este enfoque permite insertar un archivo CSV en Snowflake utilizando una fuente de Amazon S3. El archivo se coloca en etapa y luego se copia en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Para obtener información sobre cómo realizar solicitudes a Amazon S3, consulta Realizando Solicitudes en la documentación de Amazon S3.

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Amazon S3

  • Enfoque: Usa el menú desplegable para seleccionar Archivo de Etapa.

  • Tipo de Etapa: Elige Amazon S3 para recuperar datos del almacenamiento de Amazon S3.

  • Tipo de Autenticación: Elige entre usar Credenciales o Integración de Almacenamiento. Credenciales requiere el ID de clave de acceso de Amazon S3 y la clave de acceso secreta. Integración de Almacenamiento requiere solo el nombre de la integración de almacenamiento. Estos tipos de autenticación se describen a continuación.

Autenticación de credenciales

El tipo de autenticación Credenciales requiere el ID de clave de acceso de Amazon S3 y la clave de acceso secreta (para obtener información sobre cómo realizar solicitudes a Amazon S3, consulta Realizando Solicitudes en la documentación de Amazon S3).

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Amazon S3 credenciales

  • Tipo de Autenticación: Elige Credenciales.

  • ID de Clave de Acceso: Ingresa el ID de clave de acceso de Amazon S3.

  • Clave de Acceso Secreta: Ingresa la clave de acceso secreta de Amazon S3.

Autenticación de integración de almacenamiento

El tipo de autenticación de Integración de Almacenamiento requiere la creación de una integración de almacenamiento de Snowflake. Para obtener información sobre cómo crear una integración de almacenamiento de Snowflake, consulta Crear Integración de Almacenamiento en la documentación de Snowflake.

Configuración de la actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Amazon S3 integración de almacenamiento

  • Tipo de Autenticación: Elige Integración de Almacenamiento.

  • Nombre de la Integración de Almacenamiento: Ingresa el nombre de la integración de almacenamiento de Snowflake.

Opciones adicionales

Para la autenticación de Credenciales y Integración de Almacenamiento, hay estas opciones adicionales:

Configuración de la actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Amazon S3 opciones adicionales

  • Nombre del Bucket: Ingresa un nombre de bucket válido para un bucket existente en el servidor de Amazon S3. Esto se ignora si se proporciona bucketName en el esquema de datos InsertAmazonS3Request.

  • Ruta del Archivo: Ingresa la ruta del archivo.

  • En Caso de Error: Elige una de estas opciones del menú desplegable En Caso de Error; aparecerán opciones adicionales según corresponda:

    • Abort_Statement: Aborta el procesamiento si se encuentran errores.

    • Continue: Continúa cargando el archivo incluso si se encuentran errores.

    • Skip_File: Omite el archivo si se encuentran errores en el archivo.

    • Skip_File_\<num>: Omite el archivo cuando el número de errores en el archivo es igual o superior al número especificado en Número de Archivo a Omitir.

    • Skip_File_\<num>%: Omite el archivo cuando el porcentaje de errores en el archivo excede el porcentaje especificado en Porcentaje de Número de Archivo a Omitir.

  • Error en Desajuste de Conteo de Columnas: Si se selecciona, informa un error en el nodo de error del esquema de respuesta si los conteos de columnas de origen y destino no coinciden. Si no seleccionas esta opción, la operación no falla y los datos proporcionados se insertan.

  • Volver: Haz clic para regresar al paso anterior y almacenar temporalmente la configuración.

  • Siguiente: Haz clic para continuar al siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que hagas clic en el botón Finalizado en el último paso.

  • Descartar Cambios: Después de realizar cambios, haz clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje te pedirá que confirmes que deseas descartar los cambios.

Enfoque de Archivo de Etapa Interna

Este enfoque permite insertar un archivo CSV en Snowflake. El archivo será almacenado temporalmente y luego copiado en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa interna

  • Enfoque: Usa el menú desplegable para seleccionar Archivo de Etapa.

  • Tipo de Etapa: Elige Interno para recuperar los datos de una fuente interna.

  • En Caso de Error: Elige una de estas opciones del menú desplegable En Caso de Error; aparecerán opciones adicionales según sea apropiado:

    • Abortar_Declaración: Aborta el procesamiento si se encuentran errores.

    • Continuar: Continúa cargando el archivo incluso si se encuentran errores.

    • Saltar_Archivo: Salta el archivo si se encuentran errores en el archivo.

    • Saltar_Archivo_\<num>: Salta el archivo cuando el número de errores en el archivo es igual o superior al número especificado en Número de Archivo a Saltar.

    • Saltar_Archivo_\<num>%: Salta el archivo cuando el porcentaje de errores en el archivo supera el porcentaje especificado en Porcentaje de Número de Archivo a Saltar.

  • Error en Desajuste de Conteo de Columnas: Si se selecciona, informa un error en el nodo de error del esquema de respuesta si los conteos de columnas de origen y destino no coinciden. Si no seleccionas esta opción, la operación no falla y los datos proporcionados se insertan.

  • Volver: Haz clic para regresar al paso anterior y almacenar temporalmente la configuración.

  • Siguiente: Haga clic para continuar al siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que haga clic en el botón Finalizado en el último paso.

  • Descartar Cambios: Después de realizar cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le pide que confirme que desea descartar los cambios.

Enfoque de archivo de etapa de Google Cloud Storage

Este enfoque permite insertar un archivo CSV en Google Cloud Storage. El archivo se almacenará temporalmente y luego se copiará en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Google Cloud Storage

  • Enfoque: Use el menú desplegable para seleccionar Archivo de Etapa.

  • Tipo de Etapa: Elija Google Cloud Storage para recuperar los datos de una fuente interna.

  • Nombre de Integración de Almacenamiento: Ingrese el nombre de la integración de almacenamiento de Snowflake.

  • Nombre del Bucket: Ingrese un nombre de bucket válido para un bucket existente en Google Cloud Storage. Esto se ignora si se proporciona bucketName en el esquema de datos InsertGoogleCloudRequest.

  • Ruta del Archivo: Ingrese la ruta del archivo.

  • En Caso de Error: Elija una de estas opciones del menú desplegable En Caso de Error; aparecerán opciones adicionales según corresponda:

    • Abortar_Declaración: Aborta el procesamiento si se encuentran errores.

    • Continuar: Continúa cargando el archivo incluso si se encuentran errores.

    • Saltar_Archivo: Salta el archivo si se encuentran errores en el archivo.

    • Saltar_Archivo_\<num>: Salta el archivo cuando el número de errores en el archivo es igual o superior al número especificado en Número de Archivo a Saltar.

    • Saltar_Archivo_\<num>%: Salta el archivo cuando el porcentaje de errores en el archivo supera el porcentaje especificado en Porcentaje de Número de Archivo a Saltar.

  • Error en la discrepancia de conteo de columnas: Si se selecciona, informa un error en el nodo de error del esquema de respuesta si los conteos de columnas de origen y destino no coinciden. Si no selecciona esta opción, la operación no falla y los datos proporcionados se insertan.

  • Atrás: Haga clic para regresar al paso anterior y almacenar temporalmente la configuración.

  • Siguiente: Haga clic para continuar al siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que haga clic en el botón Finalizado en el último paso.

  • Descartar cambios: Después de realizar cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le pide que confirme que desea descartar los cambios.

Enfoque de archivo de etapa de Microsoft Azure

Este enfoque permite insertar un archivo CSV en Snowflake utilizando una fuente de Microsoft Azure. El archivo se coloca en etapa y luego se copia en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Microsoft Azure

  • Enfoque: Use el menú desplegable para seleccionar Archivo de etapa.

  • Tipo de etapa: Elija Microsoft Azure para recuperar datos de los contenedores de almacenamiento de Microsoft Azure.

  • Tipo de autenticación: Elija entre usar Credenciales o Integración de almacenamiento. Credenciales requiere un token de firma de acceso compartido (SAS) de Microsoft Azure y un nombre de cuenta de almacenamiento. Integración de almacenamiento requiere solo un nombre de integración de almacenamiento. Estos tipos de autenticación se cubren a continuación.

Autenticación de credenciales

El tipo de autenticación Credenciales requiere un token SAS de Microsoft Azure y un nombre de cuenta de almacenamiento.

Configuración de actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Microsoft Azure credenciales

  • Tipo de Autenticación: Elija Credenciales.

  • Token SAS de Azure: Ingrese el token SAS de Microsoft Azure. Para obtener información sobre cómo crear tokens SAS para contenedores de almacenamiento en Microsoft Azure, consulte Crear tokens SAS para sus contenedores de almacenamiento en la documentación de Microsoft Azure.

  • Nombre de la Cuenta de Almacenamiento: Ingrese el nombre de la cuenta de almacenamiento de Microsoft Azure.

Autenticación de integración de almacenamiento

El tipo de autenticación Integración de Almacenamiento requiere la creación de una integración de almacenamiento de Snowflake. Para obtener información sobre cómo crear una integración de almacenamiento de Snowflake, consulte Crear Integración de Almacenamiento en la documentación de Snowflake.

Configuración de la actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Microsoft Azure integración de almacenamiento

  • Tipo de Autenticación: Elija Integración de Almacenamiento.

  • Nombre de la Integración de Almacenamiento: Ingrese el nombre de la integración de almacenamiento de Snowflake.

Opciones adicionales

Para la autenticación Credenciales y Integración de Almacenamiento, hay estas opciones adicionales:

Configuración de la actividad de inserción de Snowflake paso 2 enfoque de archivo de etapa de Microsoft Azure opciones adicionales

Para obtener información sobre el CSE de almacenamiento en Microsoft Azure, consulte Cifrado del lado del cliente para blobs en la documentación de Microsoft Azure.

  • Nombre del Contenedor: Ingrese un nombre de bucket válido para un contenedor de almacenamiento existente en Microsoft Azure. Esto se ignora si se proporciona containerName en el esquema de datos InsertMicrosoftAzureCloudRequest.

  • Ruta del Archivo: Ingrese la ruta del archivo.

  • En Caso de Error: Elija una de estas opciones del menú desplegable En Caso de Error; aparecerán opciones adicionales según corresponda:

    • Abortar_Declaración: Aborta el procesamiento si se encuentran errores.

    • Continuar: Continúa cargando el archivo incluso si se encuentran errores.

    • Saltar_Archivo: Salta el archivo si se encuentran errores en el archivo.

    • Saltar_Archivo_\<num>: Salta el archivo cuando el número de errores en el archivo es igual o superior al número especificado en Número de Archivo a Saltar.

    • Saltar_Archivo_\<num>%: Salta el archivo cuando el porcentaje de errores en el archivo supera el porcentaje especificado en Porcentaje de Número de Archivo a Saltar.

  • Error en Desajuste de Conteo de Columnas: Si se selecciona, informa un error en el nodo de error del esquema de respuesta si los conteos de columnas de origen y destino no coinciden. Si no selecciona esta opción, la operación no falla y los datos proporcionados se insertan.

  • Atrás: Haga clic para regresar al paso anterior y almacenar temporalmente la configuración.

  • Siguiente: Haga clic para continuar al siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que haga clic en el botón Finalizado en el último paso.

  • Descartar Cambios: Después de realizar cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le pedirá que confirme que desea descartar los cambios.

Paso 3: Revisar los esquemas de datos

Se muestran los esquemas de solicitud y respuesta generados desde el punto final. Los esquemas mostrados dependen del Enfoque especificado en el paso anterior.

Estas subsecciones describen las estructuras de solicitud y respuesta para cada combinación de enfoque y tipo de etapa:

Estas acciones están disponibles con cada enfoque:

  • Esquemas de datos: Estos esquemas de datos son heredados por transformaciones adyacentes y se muestran nuevamente durante el mapeo de transformaciones.

    Nota

    Los datos suministrados en una transformación tienen prioridad sobre la configuración de la actividad.

    Consejo

    Cuando un carácter de comilla simple (') está presente en una carga útil de solicitud, se devuelve un error de sintaxis en tiempo de ejecución. Puedes habilitar la configuración de Escapar caracteres especiales en la conexión para permitir que la actividad escape automáticamente los caracteres de comilla simple (') en tiempo de ejecución.

    El conector de Snowflake utiliza la versión 3.19.0 del Controlador JDBC de Snowflake, y los comandos SQL de Snowflake. Consulta la documentación de la API para obtener información sobre los nodos y campos del esquema.

  • Actualizar: Haz clic en el ícono de actualizar o en la palabra Actualizar para regenerar esquemas desde el punto final de Snowflake. Esta acción también regenera un esquema en otras ubicaciones a lo largo del proyecto donde se hace referencia al mismo esquema, como en una transformación adyacente.

  • Atrás: Haz clic para almacenar temporalmente la configuración de este paso y regresar al paso anterior.

  • Terminado: Haz clic para guardar la configuración de todos los pasos y cerrar la configuración de la actividad.

  • Descartar Cambios: Después de realizar cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le pide que confirme que desea descartar los cambios.

Enfoque de Inserción SQL

Si el enfoque es Inserción SQL, se mostrarán las columnas de la tabla, permitiendo que se mapeen en una transformación.

Configuración de la actividad de inserción de Snowflake paso 3 enfoque de inserción SQL

  • Solicitud

    Campo/Nodo del Esquema de Solicitud Notas
    table Nodo que muestra el nombre de la tabla.
    column_A Nombre de la primera columna de la tabla.
    column_B Nombre de la segunda columna de la tabla.
    . . . Columnas sucesivas de la tabla.

  • Respuesta

    Campo/Nodo del Esquema de Respuesta Notas
    status Bandera booleana que indica si la inserción del registro fue exitosa.
    errorMessage Mensaje de error descriptivo si hay un fallo durante la inserción.
    recordsInserted Número de registros insertados si la inserción fue exitosa.

Enfoque de Archivo de Etapa de Amazon S3

Si el enfoque es Archivo de Etapa de Amazon S3, se mostrarán las especificaciones para la preparación e inserción de un archivo CSV en el esquema de datos para que puedan ser mapeadas en una transformación. El patrón utilizado es para coincidir solo un archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de la actividad de inserción de Snowflake paso 3 enfoque de archivo de etapa de Amazon S3

  • Solicitud

    Campo/Nodo del Esquema de Solicitud Notas
    accessKey ID de clave de acceso de Amazon S3.
    secretAccessKey Clave de acceso secreta de Amazon S3.
    storageintegrationName Nombre de la integración de almacenamiento de Snowflake que se utilizará para la autenticación de integración de almacenamiento de Snowflake.
    bucketName Nombre de bucket válido para un bucket existente en el servidor de Amazon S3.
    filePath Ubicación del archivo de etapa en el bucket de Amazon S3.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en la etapa; si compression es GZIP, se agrega [.]gz al patrón.
    onError Opción En Error seleccionada.
    encryption Nodo que representa la encriptación.
    encryptionType Tipo de encriptación de Amazon S3 (ya sea encriptación del lado del servidor o encriptación del lado del cliente).
    masterKey Clave maestra de Amazon S3.
    kmsKeyId ID maestro del Servicio de Gestión de Claves de Amazon.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá en SQL NULL; por defecto, es una cadena vacía. Consulta la opción NULL_IF de la documentación de Snowflake COPY INTO <location>.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulta la opción FIELD_OPTIONALLY_ENCLOSED_BY de la documentación de Snowflake COPY INTO <location>.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o un carácter de comilla doble ". Para usar el carácter de comilla simple, utiliza la representación octal ' o la representación hexadecimal 0x27, o usa un escape de comillas simples dobles ''. Cuando un campo contiene este carácter, escápalo usando el mismo carácter.
    compression El algoritmo de compresión utilizado para los archivos de datos. Se admiten GZIP o NONE. Consulta la opción Compresión de la documentación de Snowflake COPY INTO <location>.
    skipHeader Número de líneas al inicio del archivo fuente que se deben omitir.
    errorOnColumnCountMismatch Bandera booleana para informar un error si los conteos de esquema de respuesta fuente y destino no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulta la opción FIELD_DELIMITER de la documentación de Snowflake COPY INTO <table>.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulta la opción RECORD_DELIMITER de la documentación de Snowflake COPY INTO <table>.

  • Respuesta

    Campo/Nodo del Esquema de Respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV en espera procesado al insertar datos en la tabla de Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas del archivo CSV en la tabla de Snowflake sin error.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que causan que el archivo sea omitido según lo establecido en Skip_File_\<num>.
    errors_seen Conteo de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de la primera línea del primer error.
    first_error_character El primer carácter del primer error.
    first_error_column_name El nombre de la columna de la ubicación del primer error.

Enfoque de Archivo de Etapa de Google Cloud Storage

Si el enfoque es Archivo de Etapa de Google Cloud Storage, las especificaciones para la preparación e inserción de un archivo CSV se mostrarán en el esquema de datos para que puedan ser mapeadas en una transformación. El patrón utilizado es para coincidir solo un archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de la actividad de inserción de Snowflake paso 3 enfoque de archivo de Google Cloud Storage

  • Solicitud

    Campo/Nodo del Esquema de Solicitud Notas
    storageintegrationName Nombre de la integración de almacenamiento de Snowflake que se utilizará para la autenticación de la integración de almacenamiento de Snowflake.
    bucketName Nombre de bucket válido para un bucket existente en Google Cloud Storage.
    filePath Ubicación del archivo de etapa en el bucket de Google Cloud Storage.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en la etapa; si compressData es verdadero, se agrega [.]gz al patrón.
    onError Opción En Error seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá en SQL NULL; por defecto, es una cadena vacía. Consulta la opción NULL_IF de la documentación de Snowflake COPY INTO <location>.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulta la opción FIELD_OPTIONALLY_ENCLOSED_BY de la documentación de Snowflake COPY INTO <location>.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o un carácter de comilla doble ". Para usar el carácter de comilla simple, utiliza las representaciones octales ' o hexadecimales 0x27, o usa una doble comilla simple de escape ''. Cuando un campo contiene este carácter, escápalo usando el mismo carácter.
    compression El algoritmo de compresión utilizado para los archivos de datos. Se admiten GZIP o NONE. Consulta la opción Compresión de la documentación de Snowflake COPY INTO <location>.
    skipHeader Número de líneas al inicio del archivo fuente que se deben omitir.
    errorOnColumnCountMismatch Bandera booleana para informar un error si los recuentos de esquema de respuesta fuente y destino no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulta la opción FIELD_DELIMITER de la documentación de Snowflake COPY INTO <table>.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulta la opción RECORD_DELIMITER de la documentación de Snowflake COPY INTO <table>.

  • Respuesta

    Campo/Nodo del Esquema de Respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV en etapa procesado al insertar datos en la tabla de Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas del archivo CSV en la tabla de Snowflake sin error.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que causan que el archivo sea omitido según lo establecido en Skip_File_\<num>.
    errors_seen Conteo de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de la primera línea del primer error.
    first_error_character El primer carácter del primer error.
    first_error_column_name El nombre de la columna de la ubicación del primer error.

Enfoque de Archivo de Etapa Interna

Si el enfoque es Archivo de Etapa Interna, las especificaciones para la etapa e inserción de un archivo CSV se mostrarán en el esquema de datos para que puedan ser mapeadas en una transformación. El patrón utilizado es para coincidir solo un archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de la actividad de inserción de Snowflake paso 3 enfoque de archivo interno

  • Solicitud

    Campo/Nodo del Esquema de Solicitud Notas
    stageName Etapa interna de Snowflake, nombre de tabla o ruta.
    destinationPrefix Ruta o prefijo bajo el cual se cargarán los datos en la etapa de Snowflake.
    fileContent Contenidos del archivo de datos, en formato CSV, que se van a preparar para cargar en la tabla de Snowflake.
    destinationFileName Nombre del archivo de destino que se utilizará en la etapa de Snowflake.
    compressData Bandera booleana que indica si se debe comprimir los datos antes de cargarlos en la etapa interna de Snowflake.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en la etapa; si compressData es verdadero, se agrega [.]gz al patrón.
    onError Opción En Error seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá en SQL NULL; por defecto, es una cadena vacía. Consulta la opción NULL_IF de la documentación de Snowflake COPY INTO <location>.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulta la opción FIELD_OPTIONALLY_ENCLOSED_BY de la documentación de Snowflake COPY INTO <location>.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o un carácter de comilla doble ". Para usar el carácter de comilla simple, utiliza las representaciones octales ' o hexadecimales 0x27, o usa una doble comilla simple de escape ''. Cuando un campo contiene este carácter, escápalo usando el mismo carácter.
    errorOnColumnCountMismatch Bandera booleana para informar un error si los conteos de esquema de respuesta fuente y destino no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulta la opción FIELD_DELIMITER de la documentación de Snowflake COPY INTO <table>.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulta la opción RECORD_DELIMITER de la documentación de Snowflake COPY INTO <table>.

  • Respuesta

    Campo/Nodo del Esquema de Respuesta Notas
    file Nombre del archivo CSV en etapa procesado al insertar datos en la tabla de Snowflake.
    status Estado devuelto.
    rowsParsed Número de filas analizadas del archivo CSV.
    rowsLoaded Número de filas cargadas del archivo CSV en la tabla de Snowflake sin error.
    error Nodo que representa los mensajes de error.
    error El mensaje de error.
    code El código de error devuelto.
    sqlState El código de error numérico del estado SQL devuelto de la llamada a la base de datos.
    file Nodo que representa los mensajes de error.
    columnName Nombre y orden de la columna que contenía el error.
    rowNumber El número de la fila en el archivo fuente donde se encontró el error.
    rowStartLine El número de la primera línea de la fila donde se encontró el error.

Enfoque de Archivo de Etapa de Microsoft Azure

Si el enfoque es Archivo de Etapa de Microsoft Azure, las especificaciones para la etapa e inserción de un archivo CSV se mostrarán en el esquema de datos para que puedan ser mapeadas en una transformación. El patrón utilizado es para coincidir solo un archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de la actividad de inserción de Snowflake paso 3 enfoque de archivo de Microsoft Azure

  • Solicitud

    Campo/Nodo del Esquema de Solicitud Notas
    azureSasToken Token de Firma de Acceso Compartido (SAS) de Microsoft Azure.
    azureStorageAccountName Nombre de la Cuenta de Almacenamiento de Microsoft Azure.
    azureStorageintegrationName Nombre de la integración de almacenamiento de Snowflake que se utilizará para la autenticación de la integración de almacenamiento de Snowflake.
    containerName Nombre de contenedor válido para un contenedor de almacenamiento existente en Microsoft Azure.
    filePath Ubicación del archivo de etapa en el contenedor de almacenamiento de Microsoft Azure.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en la etapa; si compression es GZIP, se añade [.]gz al patrón.
    onError Opción En Error seleccionada.
    encryption Nodo que representa la encriptación.
    encryptionType Tipo de encriptación de Microsoft Azure (solo encriptación del lado del cliente).
    azureMasterKey Clave Maestra de Microsoft Azure.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá en NULL de SQL; por defecto, es una cadena vacía. Consulta la opción NULL_IF de la documentación de Snowflake COPY INTO <location>.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulta la opción FIELD_OPTIONALLY_ENCLOSED_BY de la documentación de Snowflake COPY INTO <location>.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o un carácter de comilla doble ". Para usar el carácter de comilla simple, utiliza las representaciones octales ' o hexadecimales 0x27, o usa un escape de comillas simples dobles ''. Cuando un campo contiene este carácter, escápalo usando el mismo carácter.
    compression El algoritmo de compresión utilizado para los archivos de datos. Se admiten GZIP o NONE. Consulta la opción Compresión de la documentación de Snowflake COPY INTO <location>.
    skipHeader Número de líneas al inicio del archivo fuente que se deben omitir.
    errorOnColumnCountMismatch Bandera booleana para informar un error si los conteos de esquema de respuesta fuente y destino no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulta la opción FIELD_DELIMITER de la documentación de Snowflake COPY INTO <table>.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulta la opción RECORD_DELIMITER de la documentación de Snowflake COPY INTO <table>.

  • Respuesta

    Campo/Nodo del Esquema de Respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV en espera procesado al insertar datos en la tabla de Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas del archivo CSV en la tabla de Snowflake sin errores.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que causan que el archivo sea omitido según lo establecido en Skip_File_\<num>.
    errors_seen Conteo de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de la primera línea del primer error.
    first_error_character El primer carácter del primer error.
    first_error_column_name El nombre de la columna de la ubicación del primer error.

Siguientes pasos

Después de configurar una actividad de Insertar en Snowflake, completa la configuración de la operación añadiendo y configurando otras actividades o herramientas como pasos de operación. También puedes configurar los ajustes de la operación, que incluyen la capacidad de encadenar operaciones que están en los mismos o diferentes flujos de trabajo.

Las acciones del menú para una actividad son accesibles desde el panel del proyecto y el lienzo de diseño. Para más detalles, consulta el menú de acciones de actividad en Conceptos básicos de conectores.

Las actividades de Snowflake Insert se pueden utilizar como un objetivo con estos patrones de operación:

Para usar la actividad con funciones de scripting, escribe los datos en una ubicación temporal y luego utiliza esa ubicación temporal en la función de scripting.

Cuando estés listo, despliega y ejecuta la operación y valida el comportamiento revisando los registros de operación.