Saltar al contenido

Actividad de inserción de Snowflake

Introducción

Una actividad Insertar de Snowflake, que utiliza su conexión de Snowflake, inserta datos de la tabla (ya sea como un archivo CSV o directamente asignados a las columnas de una tabla) en Snowflake y está destinado a ser utilizado como un destino para consumir datos en una operación.

Crear una actividad de inserción de Snowflake

Se crea una instancia de una actividad Insertar de Snowflake a partir de una conexión Snowflake utilizando su tipo de actividad Insertar.

Para crear una instancia de una actividad, arrastre el tipo de actividad al tela de diseño o copie el tipo de actividad y péguelo en el tela de diseño. Para obtener más detalles, consulte Creación de una instancia de actividad en Reutilización de componentes.

Se puede editar una actividad Insertar de Snowflake existente desde estas ubicaciones:

Configurar una actividad de inserción de Snowflake

Siga estos pasos para configurar una actividad Insertar de Snowflake:

Paso 1: Ingrese un nombre y seleccione un objeto

En este paso, proporcione un nombre para la actividad y seleccione una tabla o vista (consulte Descripción general de las vistas de Snowflake). A continuación se describe cada elemento de la interfaz de usuario de este paso.

Paso 1 de configuración de la actividad Insertar Snowflake

  • Nombre: Ingrese un nombre para identificar la actividad. El nombre debe ser único para cada actividad de Snowflake Insertar y no debe contener barras diagonales / o dos puntos :.

  • Seleccionar un objeto: Esta sección muestra los objetos disponibles en el extremo de Snowflake. Al volver a abrir una configuración de actividad existente, solo se muestra el objeto seleccionado en lugar de volver a cargar la lista completa de objetos.

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

    • Buscar: Ingrese 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 ya se muestran objetos en la tabla, los resultados de la tabla se filtran en tiempo real con cada pulsación de tecla. Para volver a cargar objetos desde el extremo durante la búsqueda, ingrese los criterios de búsqueda y luego actualice, como se describe a continuación.

    • Actualizar: Haga clic en el ícono de actualización Ícono de actualización o la palabra Refresh para recargar objetos desde el extremo de Snowflake. Esto puede resultar útil si se han agregado objetos a Snowflake. Esta acción actualiza todos los metadatos utilizados para crear la tabla de objetos que se muestran en la configuración.

    • Selección de un objeto: Dentro de la tabla, haga 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 desde el extremo de Snowflake:

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

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

    Consejo

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

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

  • Siguiente: Haga clic para almacenar temporalmente la configuración de este paso y continuar con el siguiente paso. La configuración no se guardará hasta que haga clic en el botón Terminado 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 solicitará que confirme que desea descartar los cambios.

Paso 2: Seleccionar un enfoque

Se admiten distintos enfoques para insertar datos en Snowflake. Elija entre Inserción SQL o Archivo de prueba. Cuando utilice el enfoque Archivo de prueba, seleccione los tipos de archivo de prueba Amazon S3 o Internal.

Enfoque de inserción de SQL

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

Paso 2 de la configuración de la actividad de inserción de Snowflake : enfoque de inserción de SQL

  • Enfoque: Utilice el menú desplegable para seleccionar Insertar SQL.

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

  • Siguiente: Haga clic para continuar con el siguiente paso y almacenar temporalmente la configuración. La configuración no se guardará hasta que haga clic en el botón Terminado 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 solicitará que confirme que desea descartar los cambios.

Enfoque de archivo de etapa de Amazon S3

Este enfoque permite insertar un archivo CSV en Snowflake mediante una fuente de Amazon S3. El archivo se almacena en una instancia temporal 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, consulte Realizar solicitudes en la documentación de Amazon S3.

Enfoque del archivo de etapa de Amazon S3 del paso 2 de configuración de la actividad de inserción de Snowflake

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

  • Tipo de etapa: Elija Amazon S3 para recuperar datos del almacenamiento de Amazon S3.

  • Tipo de autenticación: Elija entre el uso de Credenciales o Integración de almacenamiento. Credenciales requiere la 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 la 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, consulte Realizar solicitudes en la documentación de Amazon S3).

Credenciales de aproximación del archivo de etapa de Amazon S3 del paso 2 de configuración de la actividad de inserción de Snowflake

  • Tipo de autenticación: Elija Credenciales.

  • ID de clave de acceso: Ingrese la ID de clave de acceso de Amazon S3.

  • Clave de acceso secreta: Ingrese la clave de acceso secreta de Amazon S3.

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.

Paso 2 de la configuración de la actividad de inserción de Snowflake : integración del almacenamiento con el archivo de etapa de Amazon S3

  • Tipo de autenticación: Elija Integración de almacenamiento.

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

Opciones adicionales

Tanto para la autenticación de Credenciales como de Integración de almacenamiento, existen estas opciones adicionales:

Opciones adicionales del paso 2 de configuración de la actividad de inserción de Snowflake en el archivo de etapa de Amazon S3

  • Nombre del depósito: Ingrese un nombre de depósito válido para un depósito existente en el servidor Amazon S3. Esto se ignora si bucketName se suministra en el esquema de datos InsertAmazonS3Request.

  • 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:

    • Abort_Statement: Cancela el procesamiento si se encuentran errores.

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

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

    • Skip_File_\<num>: Omite el archivo cuando la cantidad de errores en el archivo es igual o mayor que el número especificado en Omitir número de archivo.

    • 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 omitido.

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

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

  • Siguiente: Haga clic para continuar con el siguiente paso y guardar 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 los cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le solicitará que confirme que desea descartar los cambios.

Enfoque de archivo de etapa interna

Este enfoque permite insertar un archivo CSV en Snowflake. El archivo se almacenará en una instancia temporal y luego se copiará en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Aproximación del archivo de etapa interna del paso 2 de configuración de la actividad de inserción de Snowflake

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

  • Tipo de etapa: Elija Interno para recuperar los datos de una fuente interna.

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

    • Abort_Statement: Cancela el procesamiento si se encuentran errores.

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

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

    • Skip_File_\<num>: Omite el archivo cuando la cantidad de errores en el archivo es igual o mayor que el número especificado en Omitir número de archivo.

    • 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 omitido.

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

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

  • Siguiente: Haga clic para continuar con el siguiente paso y guardar 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 los cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le solicitará 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á en una instancia temporal y luego se copiará en la tabla siguiendo las especificaciones del esquema de datos de la solicitud.

Paso 2 de la configuración de la actividad de inserción de Snowflake : enfoque del archivo de etapa de Google Cloud Storage

  • Enfoque: Utilice 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 depósito: Ingrese un nombre de depósito válido para un depósito existente en Google Cloud Storage. Esto se ignora si bucketName se suministra 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:

    • Abort_Statement: Cancela el procesamiento si se encuentran errores.

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

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

    • Skip_File_\<num>: Omite el archivo cuando la cantidad de errores en el archivo es igual o mayor que el número especificado en Omitir número de archivo.

    • 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 omitido.

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

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

  • Siguiente: Haga clic para continuar con el siguiente paso y guardar 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 los cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le solicitará que confirme que desea descartar los cambios.

Enfoque de archivo de prueba de Microsoft Azure

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

Paso 2 de la configuración de la actividad de inserción de Snowflake : enfoque del archivo de prueba de Microsoft Azure

  • Enfoque: Utilice 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 el uso de 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 describen 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.

Paso 2 de configuración de la actividad de inserción de Snowflake Credenciales de aproximación al archivo de etapa de Microsoft Azure

  • 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.

Paso 2 de la configuración de la actividad de inserción de Snowflake Enfoque de archivo de etapa de Microsoft Azure Integración de almacenamiento

  • Tipo de autenticación: Elija Integración de almacenamiento.

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

Opciones adicionales

Tanto para la autenticación de Credenciales como de Integración de almacenamiento, existen estas opciones adicionales:

Opciones adicionales del paso 2 de configuración de la actividad de inserción de Snowflake en el enfoque del archivo de etapa de Microsoft Azure

  • Clave maestra: Ingrese la clave maestra utilizada para el cifrado del lado del cliente (CSE) en Microsoft Azure. Esto se ignora si azureMasterKey se suministra en el esquema de datos InsertMicrosoftAzureCloudRequest.

    Nota

    Para obtener información sobre cómo crear claves en Microsoft Azure, consulte Inicio rápido: Establecer y recuperar una clave de Azure Key Vault mediante el portal de Azure en la documentación de Microsoft Azure.

    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 depósito válido para un contenedor de almacenamiento existente en Microsoft Azure. Esto se ignora si containerName se suministra 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:

    • Abort_Statement: Cancela el procesamiento si se encuentran errores.

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

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

    • Skip_File_\<num>: Omite el archivo cuando la cantidad de errores en el archivo es igual o mayor que el número especificado en Omitir número de archivo.

    • 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 omitido.

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

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

  • Siguiente: Haga clic para continuar con el siguiente paso y guardar 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 los cambios, haga clic para cerrar la configuración sin guardar los cambios realizados en ningún paso. Un mensaje le solicitará 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 extremo. Los esquemas que se muestran 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 transformación.

    Nota

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

    Consejo

    Cuando se usa 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. Puede habilitar la configuración Escape de caracteres especiales en connection para permitir que la actividad escape automáticamente los caracteres de comillas simples (') en tiempo de ejecución.

    El conector Snowflake utiliza el controlador JDBC de Snowflake y los comandos SQL de Snowflake. Consulte la documentación de la API para obtener información sobre los nodos y campos del esquema.

  • Actualizar: Haga clic en el ícono de actualización Icono de actualización o la palabra Actualizar para regenerar esquemas desde el extremo de Snowflake. Esta acción también regenera un esquema en otras ubicaciones en todo el proyecto donde se hace referencia al mismo esquema, como en una transformación adyacente.

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

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

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

Enfoque de inserción de SQL

Si el enfoque es Insertar SQL, se mostrarán las columnas de la tabla, lo que permitirá mapearlas en una transformación.

Paso 3 de la configuración de la actividad de inserción de Snowflake : enfoque de inserción de 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 de tabla siguientes.
  • Respuesta

    Campo/nodo del esquema de respuesta Notas
    status Bandera booleana que indica si la inserción del registro fue exitosa.TABLEROWEND
    errorMessage Mensaje de error descriptivo si ocurre un error durante la inserción.
    recordsInserted Número de registros insertados si la inserción es exitosa.

Enfoque de archivo de etapa de Amazon S3

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

Enfoque del archivo de etapa de Amazon S3 del paso 3 de configuración de la actividad de inserción de Snowflake

  • 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 la integración de almacenamiento de Snowflake.
    bucketName Nombre de depósito válido para un depósito existente en el servidor 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 el escenario; si compression es GZIP, [.]gzse añade al patrón.TABLEROWEND
    onError Opción En caso de error seleccionada.
    encryption Nodo que representa el cifrado.
    encryptionType Tipo de cifrado de Amazon S3 (ya sea cifrado del lado del servidor o cifrado del lado del cliente).
    masterKey Clave maestra de Amazon S3.
    kmsKeyId Servicio de gestión de claves de Amazon Identificación maestra.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá a SQL NULL; de forma predeterminada, es una cadena vacía. Consulte NULL_IF opción del Snowflake COPY INTO<location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulte FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO<location> documentación.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o carácter de comillas dobles " Para utilizar el carácter de comilla simple, utilice el sistema octal ' o el maleficio 0x27 representaciones o utilizar comillas simples dobles para escapar ''. Cuando un campo contiene este carácter, escápelo utilizando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE Se admiten. Consulte la Opción de compresión del Snowflake COPY INTO<location> documentación.
    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 origen y destino del esquema de respuesta no coinciden.TABLEROWEND
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulte FIELD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulte RECORD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
  • Respuesta

    Campo/nodo del esquema de respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV preparado que se procesa al insertar datos en la tabla Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas desde el archivo CSV en la tabla Snowflake sin errores.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que hacen que se omita el archivo según lo establecido en Skip_File_\<num>.
    errors_seen Número de errores observados.
    first_error El primer error en el archivo fuente.
    first_error_line El primer número de línea del primer error.
    first_error_character El primer caracter del primer error.
    first_error_column_name El nombre de la columna de la primera ubicación del error.

Enfoque de archivo de etapa de Google Cloud Storage

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

Paso 3 de la configuración de la actividad de inserción de Snowflake : enfoque del archivo de etapa 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 depósito válido para un depósito existente en Google Cloud Storage.
    filePath Ubicación del archivo de etapa en el depósito de Google Cloud Storage.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en el escenario; si compressData es cierto, [.]gzse añade al patrón.TABLEROWEND
    onError Opción En caso de error seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá a SQL NULL; de forma predeterminada, es una cadena vacía. Consulte NULL_IF opción del Snowflake COPY INTO<location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulte FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO<location> documentación.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o carácter de comillas dobles " Para utilizar el carácter de comilla simple, utilice el sistema octal ' o el maleficio 0x27 representaciones o utilizar comillas simples dobles para escapar ''. Cuando un campo contiene este carácter, escápelo utilizando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE Se admiten. Consulte la Opción de compresión del Snowflake COPY INTO<location> documentación.
    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 origen y destino del esquema de respuesta no coinciden.TABLEROWEND
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulte FIELD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulte RECORD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
  • Respuesta

    Campo/nodo del esquema de respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV preparado que se procesa al insertar datos en la tabla Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas desde el archivo CSV en la tabla Snowflake sin errores.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que hacen que se omita el archivo según lo establecido en Skip_File_\<num>.
    errors_seen Número de errores observados.
    first_error El primer error en el archivo fuente.
    first_error_line El primer número de línea del primer error.
    first_error_character El primer caracter del primer error.
    first_error_column_name El nombre de la columna de la primera ubicación del error.

Enfoque de archivo de etapa interna

Si el enfoque es Archivo de prueba interno, las especificaciones para preparar e insertar un archivo CSV se mostrarán en el esquema de datos para que se puedan asignar en una transformación. El patrón utilizado es hacer coincidir solo un archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Aproximación del archivo de etapa interna del paso 3 de configuración de la actividad de inserción de Snowflake

  • 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 Snowflake.
    fileContent Contenido del archivo de datos, en formato CSV, que se preparará para cargarlo en la tabla Snowflake.
    destinationFileName Nombre del archivo de destino que se utilizará en la etapa Snowflake.
    compressData Indicador booleano que indica si se deben 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 el escenario; si compressData es cierto, [.]gzse añade al patrón.TABLEROWEND
    onError Opción En caso de error seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá a SQL NULL; de forma predeterminada, es una cadena vacía. Consulte NULL_IF opción del Snowflake COPY INTO<location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulte FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO<location> documentación.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o carácter de comillas dobles " Para utilizar el carácter de comilla simple, utilice el sistema octal ' o el maleficio 0x27 representaciones o utilizar comillas simples dobles para escapar ''. Cuando un campo contiene este carácter, escápelo utilizando el mismo carácter.

    errorOnColumnCountMismatch Bandera booleana para informar un error si los recuentos de origen y destino del esquema de respuesta no coinciden.TABLEROWEND
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulte FIELD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulte RECORD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
  • Respuesta

    Campo/nodo del esquema de respuesta Notas
    file Nombre del archivo CSV preparado que se procesa al colocar datos en la tabla Snowflake.
    status Estado devuelto.
    rowsParsed Número de filas analizadas del archivo CSV.
    rowsLoaded Número de filas cargadas desde el archivo CSV en la tabla Snowflake sin errores.
    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 de origen 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 prueba de Microsoft Azure

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

Paso 3 de la configuración de la actividad de inserción de Snowflake : enfoque del archivo de prueba de Microsoft Azure

  • Solicitud

    Campo/nodo del esquema de solicitud Notas
    azureSasToken [Token de firma de acceso compartido (SAS) de Microsoft Azure ]sas-token].
    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 el escenario; si compression es GZIP, [.]gzse añade al patrón.TABLEROWEND
    onError Opción En caso de error seleccionada.
    encryption Nodo que representa el cifrado.
    encryptionType Tipo de cifrado de Microsoft Azure (sólo cifrado del lado del cliente).
    azureMasterKey Clave maestra de Microsoft Azure.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena que se convertirá a SQL NULL; de forma predeterminada, es una cadena vacía. Consulte NULL_IF opción del Snowflake COPY INTO<location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; consulte FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO<location> documentación.

    Nota

    El enclosingChar puede ser un carácter de comilla simple ' o carácter de comillas dobles " Para utilizar el carácter de comilla simple, utilice el sistema octal ' o el maleficio 0x27 representaciones o utilizar comillas simples dobles para escapar ''. Cuando un campo contiene este carácter, escápelo utilizando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE Se admiten. Consulte la Opción de compresión del Snowflake COPY INTO<location> documentación.
    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 origen y destino del esquema de respuesta no coinciden.TABLEROWEND
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; consulte FIELD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; consulte RECORD_DELIMITER opción del Snowflake COPY INTO<table> documentación.
  • Respuesta

    Campo/nodo del esquema de respuesta Notas
    status Estado devuelto.
    file Nombre del archivo CSV preparado que se procesa al insertar datos en la tabla Snowflake.
    rows_parsed Número de filas analizadas del archivo CSV.
    rows_loaded Número de filas cargadas desde el archivo CSV en la tabla Snowflake sin errores.
    error Nodo que representa los mensajes de error.
    error_limit Número de errores que hacen que se omita el archivo según lo establecido en Skip_File_\<num>.
    errors_seen Número de errores observados.
    first_error El primer error en el archivo fuente.
    first_error_line El primer número de línea del primer error.
    first_error_character El primer caracter del primer error.
    first_error_column_name El nombre de la columna de la primera ubicación del error.

Próximos pasos

Después de configurar una actividad Insertar de Snowflake, complete la configuración de la operación agregando y configurando otras actividades, transformaciones o secuencias de comandos como pasos de la operación. También puede configurar los ajustes de la operación, que incluyen la capacidad de encadenar operaciones que se encuentran en el mismo flujo de trabajo o en flujos de trabajo diferentes.

Se puede acceder a las acciones del menú de una actividad desde el panel del proyecto y el tela de diseño. Para obtener más información, consulte menú de acciones de la actividad en Conceptos básicos del conector.

Las actividades de Insertar de Snowflake se pueden usar como objetivo con estos patrones de operación:

Para utilizar la actividad con funciones de script, escriba los datos en una ubicación temporal y luego use esa ubicación temporal en la función de script.

Cuando esté listo, desplegar y ejecute la operación y validar el comportamiento comprobando los registros de operación.