Compartir a través de


Tutorial: Configuración de dbt para el almacén de datos de Fabric

Se aplica a:✅Almacenamiento de Microsoft Fabric

Este tutorial le guía por la configuración de dbt e implementación del primer proyecto en una instancia de Fabric Warehouse.

Introducción

dbt (Herramienta de compilación de datos) es un marco de código abierto que simplifica la transformación de datos y la ingeniería de análisis. Se centra en las transformaciones basadas en SQL dentro de la capa de análisis, tratando SQL como código. dbt admite el control de versiones, la modularización, las pruebas y la documentación.

El adaptador de dbt para Microsoft Fabric se puede usar para crear proyectos dbt, que luego se pueden implementar en un almacén de datos de Fabric Synapse.

También puede cambiar la plataforma de destino para el proyecto dbt simplemente cambiando el adaptador, por ejemplo; Un proyecto creado para Azure Synapse grupo de SQL dedicado se puede actualizar en unos segundos a un almacén de datos de Fabric Synapse.

Requisitos previos para el adaptador de dbt para Microsoft Fabric

Siga esta lista para instalar y configurar los requisitos previos de dbt:

  1. Versión de Python 3.7 (o superior).

  2. El controlador ODBC de Microsoft para SQL Server.

  3. La última versión del adaptador dbt-fabric del repositorio PyPI (Python Package Index) mediante pip install dbt-fabric.

    pip install dbt-fabric
    

    Nota:

    Cambiando pip install dbt-fabric a pip install dbt-synapse y siguiendo las siguientes instrucciones, puede instalar el adaptador dbt para el grupo SQL dedicado de Synapse .

  4. Asegúrese de verificar que dbt-fabric y sus dependencias estén instaladas mediante el comando pip list:

    pip list
    

    Se debe devolver una larga lista de los paquetes y las versiones actuales de este comando.

  5. Si aún no tiene una, cree un Warehouse. Puede utilizar la capacidad de prueba para este ejercicio: regístrese para la prueba gratuita de Microsoft Fabric , cree un área de trabajo y, a continuación, cree un almacén.

Introducción al adaptador de dbt-fabric

Este aprendizaje utiliza Visual Studio Code, pero puede utilizar la herramienta que prefiera.

  1. Clone el proyecto jaffle_shop demo dbt en la máquina.

    git clone https://github.com/dbt-labs/jaffle_shop.git
    
  2. Abra la carpeta de proyecto jaffle_shop en Visual Studio Code.

    Una captura de pantalla de Visual Studio Code, que muestra el proyecto abierto.

  3. Puede omitir el registro si ya ha creado un almacén.

  4. Cree un archivo profiles.yml . Añada la siguiente configuración a profiles.yml. Este archivo configura la conexión al almacenamiento en Microsoft Fabric mediante el adaptador dbt-fabric.

    config:
      partial_parse: true
    jaffle_shop:
      target: fabric-dev
      outputs:    
        fabric-dev:
          authentication: CLI
          database: <put the database name here>
          driver: ODBC Driver 18 for SQL Server
          host: <enter your SQL analytics endpoint here>
          schema: dbo
          threads: 4
          type: fabric
    

    Nota:

    Cambie el type de fabric a synapse para cambiar el adaptador de base de datos a Azure Synapse Analytics, si lo desea. Cualquier plataforma de datos del proyecto DBT existente se puede actualizar cambiando el adaptador de base de datos. Para obtener más información, consulte la lista dbt de plataformas de datos compatibles .

  5. Autentíquese en Azure en el terminal de Visual Studio Code.

  6. Ahora está listo para probar la conectividad. Ejecute dbt debug en el terminal de Visual Studio Code para probar la conectividad con su almacén.

    dbt debug
    

    Una captura de pantalla de Visual Studio Code, que muestra el comando depuración dbt.

    Todas las comprobaciones se pasan, lo que significa que puede conectar el almacén mediante el adaptador dbt-fabric desde el proyecto de jaffle_shop dbt.

  7. Ahora, es el momento de probar si el adaptador funciona o no. Primero ejecute dbt seed para insertar datos de muestra en el almacén.

    Una captura de pantalla de Visual Studio Code, que muestra un comando de posición inicial dbt.

  8. Ejecute dbt run para validar los datos contra algunas pruebas.

    dbt run
    

    Una captura de pantalla de Visual Studio Code, que muestra un comando de ejecución dbt.

  9. Ejecute dbt test para ejecutar los modelos definidos en el proyecto dbt de demostración.

    dbt test
    

    Una captura de pantalla de Visual Studio Code, que muestra un comando de prueba dbt.

Ahora ha implementado un proyecto de dbt en el almacén de datos de Synapse en Fabric.

Movimiento entre almacenes diferentes

Es sencillo mover el proyecto dbt entre diferentes almacenes. Un proyecto dbt en cualquier almacenamiento compatible se puede migrar rápidamente con este proceso de tres pasos:

  1. Instale el nuevo adaptador. Para obtener más información e instrucciones de instalación completas, consulte Adaptadores dbt .

  2. Actualice la propiedad type en el archivo profiles.yml.

  3. Compile el proyecto.

dbt en Fabric Data Factory

Cuando se integra con Apache Airflow, un popular sistema de administración de flujos de trabajo, dbt se convierte en una herramienta eficaz para orquestar transformaciones de datos. Las funcionalidades de programación y administración de tareas de Airflow permiten a los equipos de datos automatizar las ejecuciones de dbt. Garantiza actualizaciones de datos periódicas y mantiene un flujo coherente de datos de alta calidad para el análisis y los informes. Este enfoque combinado, mediante la experiencia de transformación de dbt con la administración del flujo de trabajo de Airflow, ofrece canalizaciones de datos eficaces y sólidas, lo que en última instancia conduce a decisiones controladas por datos más rápidas y detalladas.

Apache Airflow es una plataforma de código abierto que se usa para crear, programar y supervisar flujos de trabajo de datos complejos mediante programación. Permite definir un conjunto de tareas, denominadas operadores, que se pueden combinar en grafos acíclicos dirigidos (DAG) para representar canalizaciones de datos.

Para obtener más información sobre cómo poner en marcha dbt con el almacenamiento, consulte Transformación de datos mediante dbt con Data Factory en Microsoft Fabric.

Consideraciones

Aspectos importantes que se deben tener en cuenta al usar el adaptador de dbt-fabric:

  • Revise las limitaciones actuales en el almacenamiento de datos de Microsoft Fabric .

  • Fabric admite la autenticación de Microsoft Entra ID (anteriormente Azure Active Directory) para entidades de seguridad de usuario, identidades de usuario y entidades de servicio. El modo de autenticación recomendado para trabajar interactivamente en el almacenamiento es la CLI (interfaces de línea de comandos) y usar entidades de servicio para la automatización.

  • Revise los comandos T-SQL (Transact-SQL) no admitidos en el almacén de datos de Synapse en Microsoft Fabric.

  • Algunos comandos T-SQL son compatibles con el adaptador de estructura dbt-fabric mediante comandos Create Table as Select (CTAS), DROP y CREATE como ALTER TABLE ADD/ALTER/DROP COLUMN, MERGE, TRUNCATE y sp_rename.

  • Revise Tipos de datos no admitidos para obtener información sobre los tipos de datos admitidos y no admitidos.

  • Para registrar problemas en el adaptador de dbt-fabric en GitHub, visite Problemas · microsoft/dbt-fabric · GitHub.

Paso siguiente