如何在每项工作结束时实施日志记录在talend？

Question

我是Talend os的新手。

不过，我接到一个任务：

1. 创建（铅&一个机会）文件分隔符的.csv元数据。
2. 将文件移到AWS服务器上的存储库（etl_process1登录）。
3. 创建两个表sfdc_leads_reporting_raw和sfdc_opp_reporting_raw。
4. 将文件中的数据加载到表中。创建元数据模式&表时，请确保正确使用数据类型。

直到第4步我完成了。

现在的问题是：

如何在每一个工作在年底前实施记录报告引线数（线索表不同的ID的数量）和创造的机会数（机会ID的计数）分阶段（多少转换，合格，封闭赢了，死了）？

帮助将不胜感激。

Answer 1

您可以使用全局变量在作业结束时的子作业中获取此数据。大多数组件提供了一个名为tComponent_NB_LINE的全局变量（或数据库组件的_NB_LINE_INSERTED），它提供了组件输出的行数。例如tFileOutputDelimited_1_NB_LINE或tOracleOutput_1_NB_LINE_INSERTED。

使用这些变量可以登录到控制台或文件。 这是一个简单的例子。如果你有你的工作tOracleOutput_1，你可以这样做：

tPostJob -- OnComponentOk -- tFixedFlowInput -- Main -- tLogRow 

里面tFixedFlowInput您检索的变量

(Integer)globalMap.get("tOracleOutput_1_NB_LINE_INSERTED")`. 

如果您需要登录汇总信息，您可以追加一个tAggregateRow到您的输出部件，并使用tSetGlobalVar按特定标准计数。