我有一个数据管道,它将数据从csv文件写入到staging数据库表(SQL Server)中。日志记录设置为收集同一数据库中管道执行的所有数据。为了能够将数据库中新创建的数据记录链接到特定作业的日志数据,我想添加一个列Job_id到我的数据表。这将允许我检索在创建此记录时收集的日志数据。日志数据有像pipelineLogChannelId这样的字段,这似乎是管道的唯一运行时id。是否有可能在运行的管道中获得该id,以便我可以将其设置为目标数据库表中某列的值?
我尝试了不同的变换,变量。最有希望的是"执行信息";但这相当慢,而且我找不到返回管道的作业id的设置。"获取执行id"将限制设置为1且包含子节点设置为0的操作类型返回下一个转换的通道id,但不返回管道。
如果你还在寻找这个,有内部变量名可以帮助你得到你想要的结果。$ {Internal.Pipeline。ID}这将包含请求它的管道的日志通道。$ {Internal.Workflow。ID}相同,但用于工作流
此信息来自源代码,未公开记录