Saltar al contenido

Actividad de Inserción de Snowflake

Introducción

Una actividad Snowflake Insertar, usando su conexión Snowflake, inserta datos de la tabla (ya sea como un archivo CSV o asignados directamente a columnas de una tabla) en Snowflake y está diseñado para usarse como destino para consumir datos en una operación.

Crear una Actividad de Inserción de Snowflake

Se crea una instancia de una actividad Snowflake Insertar 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 cópielo y péguelo en el tela de diseño. Para obtener más información, consulte Creación de una instancia de actividad en Reutilización de componentes.

Una actividad Insertar de Snowflake existente se puede editar 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 vistas de Snowflake). Cada elemento de la interfaz de usuario de este paso se describe a continuación.

Paso 1 de configuración de actividad de inserción de Snowflake

  • Nombre: Introduzca 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 :.

  • Seleccione 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 recargar toda la lista de objetos.

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

    • Buscar: Ingrese cualquier parte del nombre del objeto 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 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 icono de actualización Icono de actualización o la palabra Actualizar 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.

    • Seleccionar un objeto: Dentro de la tabla, haga clic en cualquier lugar de una fila para seleccionar un objeto. Sólo se puede seleccionar un objeto. La información disponible para cada objeto se obtiene del 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 completa con los objetos disponibles, la Conexión de Snowflake puede no tener éxito. 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 para este paso y cerrar la configuración de la actividad.

  • Siguiente: Haga clic para almacenar temporalmente la configuración para este paso y continuar con el siguiente. 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.

Paso 2: Seleccione un Enfoque

Se admiten diferentes enfoques para insertar datos en Snowflake. Elija entre Inserción SQL o Archivo de etapa. Cuando se utiliza el método Stage File, se seleccionan los tipos de archivos de etapa Amazon S3 o Internal.

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, lo que permitirá asignarlas en una transformación.

Configuración de actividad de inserción de Snowflake Paso 2 Enfoque de inserción de SQL

  • Enfoque: Utilice el menú desplegable para seleccionar Inserción SQL.

  • Volver: Haga clic para regresar 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 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 Amazon S3

Este enfoque permite insertar un archivo CSV en Snowflake utilizando una fuente de Amazon S3. El archivo se prepara 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 Realización de 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: Utilice el menú desplegable para seleccionar Stage File.

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

  • Tipo de autenticación: Elija entre usar Credenciales o Integración de almacenamiento. Credenciales requiere el ID de la 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 tratan a continuación.

Autenticación de Credenciales

El tipo de autenticación Credenciales requiere el ID de la 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 Realización de solicitudes en la documentación de Amazon S3).

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

  • Tipo de autenticación: Elija Credenciales.

  • ID de clave de acceso: Introduzca el 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 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 actividad de inserción de Snowflake Paso 2 Integración de almacenamiento del enfoque de archivos de etapa de Amazon S3

  • 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

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

Configuración de actividad de inserción de Snowflake Paso 2 Opciones adicionales del método de archivo de etapa de Amazon S3

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

  • Ruta del archivo: Introduzca la ruta del archivo.

  • En caso de error: Elija una de estas opciones en el menú desplegable En caso de error; Aparecerán opciones adicionales según corresponda:

    • Abort_Statement: Anula el procesamiento si se encuentra algún error.

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

    • Skip_File: Omite el archivo si se encuentra algún error en él.

    • Skip_File_\<num>: Omite el archivo cuando el número de errores en el archivo iguala o excede 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 Omitir porcentaje de número de archivo.

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

  • Volver: Haga clic para regresar 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 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 Interna

Este enfoque permite insertar un archivo CSV en Snowflake. El archivo se preparará 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 interna

  • Enfoque: Utilice el menú desplegable para seleccionar Stage File.

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

  • En caso de error: Elija una de estas opciones en el menú desplegable En caso de error; Aparecerán opciones adicionales según corresponda:

    • Abort_Statement: Anula el procesamiento si se encuentra algún error.

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

    • Skip_File: Omite el archivo si se encuentra algún error en él.

    • Skip_File_\<num>: Omite el archivo cuando el número de errores en el archivo iguala o excede 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 Omitir porcentaje de número de archivo.

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

  • Volver: Haga clic para regresar 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 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 Archivos de Etapa de Google Cloud Storage

Este enfoque permite insertar un archivo CSV en Google Cloud Storage. El archivo se preparará 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: Utilice el menú desplegable para seleccionar Stage File.

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

  • Nombre de la 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 proporciona en el esquema de datos InsertGoogleCloudRequest.

  • Ruta del archivo: Introduzca la ruta del archivo.

  • En caso de error: Elija una de estas opciones en el menú desplegable En caso de error; Aparecerán opciones adicionales según corresponda:

    • Abort_Statement: Anula el procesamiento si se encuentra algún error.

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

    • Skip_File: Omite el archivo si se encuentra algún error en él.

    • Skip_File_\<num>: Omite el archivo cuando el número de errores en el archivo iguala o excede 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 Omitir porcentaje de número de archivo.

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

  • Volver: Haga clic para regresar 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 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 prepara 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: Utilice el menú desplegable para seleccionar Stage File.

  • 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 solo requiere un nombre de integración de almacenamiento. Estos tipos de autenticación se tratan 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 Credenciales de enfoque de archivo de etapa de Microsoft Azure

  • Tipo de autenticación: Elija Credenciales.

  • Token SAS de Azure: Introduzca el token SAS de Microsoft Azure. Para obtener información sobre la creación de 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: Introduzca 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 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 actividad de inserción de Snowflake Paso 2 Integración de almacenamiento del enfoque de archivos de etapa de Microsoft Azure

  • 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

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

Configuración de actividad de inserción de Snowflake Paso 2 Opciones adicionales del enfoque de 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 proporciona en el esquema de datos InsertMicrosoftAzureCloudRequest.

    Nota

    Para obtener información sobre la creación de claves en Microsoft Azure, consulte Inicio rápido: configurar 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 almacenamiento CSE 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 proporciona en el esquema de datos InsertMicrosoftAzureCloudRequest.

  • Ruta del archivo: Introduzca la ruta del archivo.

  • En caso de error: Elija una de estas opciones en el menú desplegable En caso de error; Aparecerán opciones adicionales según corresponda:

    • Abort_Statement: Anula el procesamiento si se encuentra algún error.

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

    • Skip_File: Omite el archivo si se encuentra algún error en él.

    • Skip_File_\<num>: Omite el archivo cuando el número de errores en el archivo iguala o excede 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 Omitir porcentaje de número de archivo.

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

  • Volver: Haga clic para regresar 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 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.

Paso 3: Revisar los Esquemas de Datos

Se muestran los esquemas de solicitud y respuesta generados desde el extremo. 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 se heredan mediante transformaciones adyacentes y se muestran nuevamente durante asignación de transformación.

    Nota

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

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

  • Actualizar: Haga clic en el icono 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 del proyecto donde se hace referencia al mismo esquema, como en una transformación adyacente.

  • Volver: Haga clic para almacenar temporalmente la configuración de este paso y volver 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 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 SQL Insert, se mostrarán las columnas de la tabla, lo que permitirá asignarlas en una transformación.

Configuración de actividad de inserción de Snowflake Paso 3 Enfoque de inserción de SQL

  • Pedido

    Solicitar campo/nodo de esquema 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 se produce un error durante la inserción.
    recordsInserted Número de registros insertados si la inserción se realizó correctamente.

Enfoque de Archivo de Etapa de Amazon S3

Si el enfoque es Archivo de etapa de Amazon S3, 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 un solo archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de actividad de inserción de Snowflake Paso 3 Enfoque de archivo de etapa de Amazon S3

  • Pedido

    Solicitar campo/nodo de esquema 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 depósito de Amazon S3.
    pattern Patrón de expresión regular utilizado para encontrar el archivo en el escenario; si compression es GZIP, [.]gz se adjunta al patrón.
    onError En caso de error opción 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 administración de claves de Amazon Identificación maestra.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena para convertir a SQL NULL; de forma predeterminada, es una cadena vacía. Ver el NULL_IF opción del Snowflake COPY INTO <location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; ver el FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO <location> documentación.

    Nota

    El enclosingChar puede ser una comilla simple ' o carácter de comilla doble ". Para utilizar el carácter de comilla simple, utilice el carácter octal ' o el maleficio 0x27 representaciones o utilizar un escape de comilla simple doble ''. Cuando un campo contiene este carácter, escápelo usando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE son compatibles. 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 van a omitir.
    errorOnColumnCountMismatch Indicador booleano para informar un error si los recuentos de origen y destino del esquema de respuesta no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; ver el FIELD_DELIMITER opción del Snowflake COPY INTO <table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; ver el 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 procesado 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 el archivo se omita según lo establecido en Skip_File_\<num>.
    errors_seen Recuento de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de 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 primera ubicación del error.

Enfoque de Archivos de Etapa de Google Cloud Storage

Si el enfoque es Archivo de etapa de Google Cloud Storage, 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 un solo archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de actividad de inserción de Snowflake Paso 3 Enfoque de archivo de etapa de Google Cloud Storage

  • Pedido

    Solicitar campo/nodo de esquema 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 verdad, [.]gz se adjunta al patrón.
    onError En caso de error opción seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena para convertir a SQL NULL; de forma predeterminada, es una cadena vacía. Ver el NULL_IF opción del Snowflake COPY INTO <location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; ver el FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO <location> documentación.

    Nota

    El enclosingChar puede ser una comilla simple ' o carácter de comilla doble ". Para utilizar el carácter de comilla simple, utilice el carácter octal ' o el maleficio 0x27 representaciones o utilizar un escape de comilla simple doble ''. Cuando un campo contiene este carácter, escápelo usando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE son compatibles. 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 van a omitir.
    errorOnColumnCountMismatch Indicador booleano para informar un error si los recuentos de origen y destino del esquema de respuesta no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; ver el FIELD_DELIMITER opción del Snowflake COPY INTO <table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; ver el 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 procesado 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 el archivo se omita según lo establecido en Skip_File_\<num>.
    errors_seen Recuento de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de 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 primera ubicación del error.

enfoque de Archivo de Etapa Interna

Si el enfoque es Archivo de etapa interna, 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 un solo archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de actividad de inserción de Snowflake Paso 3 Enfoque de archivo de etapa interna

  • Pedido

    Solicitar campo/nodo de esquema Notas
    stageName Etapa, nombre de tabla o ruta interna de Snowflake.
    destinationPrefix Ruta o prefijo bajo el cual se cargarán los datos en el escenario 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 el escenario Snowflake.
    compressData Indicador booleano para saber 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 verdad, [.]gz se adjunta al patrón.
    onError En caso de error opción seleccionada.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena para convertir a SQL NULL; de forma predeterminada, es una cadena vacía. Ver el NULL_IF opción del Snowflake COPY INTO <location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; ver el FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO <location> documentación.

    Nota

    El enclosingChar puede ser una comilla simple ' o carácter de comilla doble ". Para utilizar el carácter de comilla simple, utilice el carácter octal ' o el maleficio 0x27 representaciones o utilizar un escape de comilla simple doble ''. Cuando un campo contiene este carácter, escápelo usando el mismo carácter.

    errorOnColumnCountMismatch Indicador booleano para informar un error si los recuentos de origen y destino del esquema de respuesta no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; ver el FIELD_DELIMITER opción del Snowflake COPY INTO <table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; ver el 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 procesado 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 por 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 Microsoft Azure Stage File, 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 un solo archivo. Si el patrón coincide con más de un archivo, la actividad generará un error con un mensaje descriptivo.

Configuración de actividad de inserción de Snowflake Paso 3 Enfoque de archivo de etapa de Microsoft Azure

  • Pedido

    Solicitar campo/nodo de esquema 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 provisional 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, [.]gz se adjunta al patrón.
    onError En caso de error opción seleccionada.
    encryption Nodo que representa el cifrado.
    encryptionType Tipo de cifrado de Microsoft Azure (solo cifrado del lado del cliente).
    azureMasterKey Clave maestra de Microsoft Azure.
    fileFormat Nodo que representa el formato del archivo.
    nullIf Una cadena para convertir a SQL NULL; de forma predeterminada, es una cadena vacía. Ver el NULL_IF opción del Snowflake COPY INTO <location> documentación.
    enclosingChar Carácter utilizado para encerrar campos de datos; ver el FIELD_OPTIONALLY_ENCLOSED_BY opción del Snowflake COPY INTO <location> documentación.

    Nota

    El enclosingChar puede ser una comilla simple ' o carácter de comilla doble ". Para utilizar el carácter de comilla simple, utilice el carácter octal ' o el maleficio 0x27 representaciones o utilizar un escape de comilla simple doble ''. Cuando un campo contiene este carácter, escápelo usando el mismo carácter.

    compression El algoritmo de compresión utilizado para los archivos de datos. GZIP o NONE son compatibles. 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 van a omitir.
    errorOnColumnCountMismatch Indicador booleano para informar un error si los recuentos de origen y destino del esquema de respuesta no coinciden.
    fieldDelimiter El carácter delimitador utilizado para separar campos de datos; ver el FIELD_DELIMITER opción del Snowflake COPY INTO <table> documentación.
    recordDelimiter El carácter delimitador utilizado para separar grupos de campos; ver el 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 procesado 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 el archivo se omita según lo establecido en Skip_File_\<num>.
    errors_seen Recuento de errores vistos.
    first_error El primer error en el archivo fuente.
    first_error_line El número de 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 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 operación, que incluyen la capacidad de encadenar operaciones que se encuentran en el mismo flujos de trabajo o en diferentes.

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

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

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

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