Process Mining

适用平台：

上次更新日期 2025年9月18日

转换

Folder structure

重要提示：此页面上的信息仅适用于具有截止日期配置文件和seeds\文件夹的应用程序模板。

流程应用程序的转换包含一个dbt项目。下表描述了dbt项目文件夹的内容。

文件夹/文件	包含
`dbt_packages\`	`pm_utils`包及其宏。
`macros\`	自定义宏的可选文件夹
`models\`	`.sql`文件，用于定义转换。
`models\schema\`	`.yml`文件，用于定义数据测试。
`seeds`	`.csv`包含配置设置的文件。
`dbt_project.yml`	dbt项目的设置。

备注：

事件日志和自定义流程应用程序模板具有简化的数据转换结构。使用这些应用程序模板创建的流程应用程序不具有此文件夹结构。

dbt_project.yml

dbt_project.yml 文件包含用于定义转换的 dbt 项目的设置。 vars 部分包含转换中使用的变量。

日期/时间格式

每个应用程序模板都包含用于确定解析日期/时间数据的格式的变量。如果输入数据的日期/时间格式与预期不同，则必须调整这些变量。

数据转换

数据转换在models\目录下的.sql文件中定义。数据转换组织在一组标准的子目录中。

有关详细信息，请查看转换结构。

.sql文件以 Jinja SQL 编写，允许您在普通 SQL 查询中插入 Jinja 语句。当 dbt 运行所有.sql文件时，每个.sql文件都会在数据库中生成一个新视图或新表。

通常， .sql文件具有以下结构： Select * from {{ ref('Table_A') }} Table_A 。

以下代码显示了一个 SQL 查询示例。

select
    tableA."Field_1" as "Alias_1",
    tableA."Field_2",
    tableA."Field_3"
from {{ ref('tableA') }} as tableAselect
    tableA."Field_1" as "Alias_1",
    tableA."Field_2",
    tableA."Field_3"
from {{ ref('tableA') }} as tableA

备注：

在某些情况下，对于使用旧版应用程序模板创建的流程应用程序， .sql文件具有以下结构：

With 语句：一个或多个 with 语句，用于包含所需的子表。
- {{ ref(‘My_table) }}引用由另一个 .sql 文件定义的表文件。
- {{ source(var("schema_sources"), 'My_table') }}引用输入表。
主查询：定义新表的查询。
最终查询：通常在最后使用Select * from table等查询。这样可以在调试时轻松进行子选择。

有关如何有效编写转换的更多提示，请参阅编写 SQL 的提示。

Adding source tables

上传新的输入文件时，系统会在dbt项目的models\schema\sources.yml中自动添加新的源表。这样，其他模型就可以使用{{ source(var("schema_sources"), 'My_table') }}引用它。有关如何配置输入表的更多信息，请查看管理输入数据。

下图显示了一个示例。