salesforce - Talend 作业未将从 tSalesforceInput 检索到的所有行加载到雪花数据库

Question

我有一个简单的工作（如图所示），它连接到 Salesforce、获取数据并将其加载到 Snowflake 中。tFlowMeter 记录返回的行数。我看到它记录了所有行（大约 500K）都是从 tSalesforceInput 组件获得的。但是，当我查询 Snowflake DB 时，我丢失了大约 80k 行。Talend 运行成功完成。我手动检查了 Snowflake 中缺少的一些 ID，并且在行中看不到任何可能阻止它们加载到数据库中的数据。

当我查看 Snowflake 的“历史”选项卡时，我看到属性“on_error”设置为“继续”（如下面的屏幕截图所示）。如何更改 tDBOutput 组件（用于加载 Snowflake DB）中的此属性以失败并记录/抛出错误？

PS：不到两个月前，我开始在 Talend 上工作。请原谅任何愚蠢的错误。

标签： salesforceetlsnowflake-cloud-data-platformtalend

Answer 1

您应该在组件tDBOutput（基本设置选项卡）中找到一个名为Die on error的选项以激活。

这将使用on_error='ABORT_STATEMENT'而不是CONTINUE，并且在数据上传阶段出现问题时会抛出错误。