问题标签 [talend-mdm]

这是我想做的事情：

1. 新行：插入，没有 pkey 违规。完毕。
2. 现有行：pkey-violation，检查任何列值是否不同，如果是，则更新该行（无需更新特定列，更新整行）！

如何实现“检查是否有任何列值不同”？能否请您粘贴配置的屏幕剪辑。

如果 row2.id.equals(row1.id) 将其发送到错误/更新，我将同一表 LIB_USERS 的查找添加到 tMap（postgres）中。但它永远挂起！:)

我是 Talend 的初学者，我在通过 talend 处理 json 文件时遇到问题。我有一个具有多个级别的 json 文件，其中包含不同级别（或深度）的 json 表。我只想通过 thmap 在位于给定深度的 json 区域中添加一个属性。因此，在输入中我有 json 文件并在输出中具有新属性的相同 json 文件。我不知道如何配置 thmap，尽管它专门用于简化复杂的映射。

我面临实习，他们让我学习如何使用 talend ETL。我做到了，没那么难。分配给我的额外任务之一是验证我在设计工作区中设置的操作中有多少是在 java 中执行的，以及通过使用查询完成了哪些操作。我使用 TMap 组件设置了一个简单的 Join，并通过使用 SQL Profiler 监视了 SQL 数据库。结果是只有基本的创建/删除和表的选择/插入是通过 sql 完成的，而像实际连接这样的所有其他事情都是由“Java”端完成的。只要是像join这样简单的操作，不用麻烦java来执行，通过查询来执行不是很方便吗？对于那些也了解 SAP 的人来说，Talend 和 SAP 在性能方面有这么大的区别吗？

我在 oracle db 中有一个名为 abc 的表名，它有两个字段 S.No 和过程名称。我正在调用 S.No 和过程名称，其中 SNO 是我输入的（在执行作业时，它要求输入 S.No）。一旦获得与该特定 S.No 相关的过程名称，我就会将过程名称发送到 tFixedFlowInput 并从那里连接到 tDBSP (Oracle) 以执行该过程。

在 tDBSP (Oracle) 中，我想动态地给出从 tFixedFlowInput 获得的存储过程名称。因此，将来我只需要提供 S.No 作为输入，它应该执行相关的存储过程。请帮助我实现这一目标。

此外，该过程具有一个输入参数。

我有一个关于工作输出的问题。

是否有可能使工作的输出动态化？我的意思是能够通过属性或其他东西配置想要的输出？用户应该能够通过修改属性来选择他希望在哪种数据库中导入数据。

显然，这可以使用 runIf 来完成 - 不幸的是，我无法弄清楚如何做到这一点。

运行 if 只能用于布尔值。例如，当满足条件时，文件的存在（或不存在），如果返回的行数大于 100，以及无数其他条件。

如何检查上下文变量是否等于特定的字符串？例如，如果 context.test = "postgres" 那么 tpostgresqloutput，如果 context.test = "snowflake" 那么 tsnowflakeoutput？

例如

谢谢，BR

我正在尝试获取 Talend 流中的行数。我有一个看起来像这样的子作业： 如何从该流中获取行数（红色箭头所在的位置）并将该值写入另一个文档或将其存储在变量中。我知道我可以在 tMap 中使用这样的变量：

但这仍然对我没有帮助，因为我只需要总行数。我如何在 Talend 中做到这一点？

我有一个将数据从 MongoDB 加载到 SQL 服务器的 Talend 作业。要连接 MongoDB，我必须使用使用 tSetKeystore 的 JKS 文件。下面是我的工作快照。

这在 talend studio 上运行良好，但在 talend cloud (TMC) 上部署后就不行了。我在资源中上传了相同的 JKS 并将资源名称添加到上下文中，但没有运气。

我一直低于错误。对我来说，该工作似乎无法访问 JKS，但欢迎提出任何建议。

很难为这个问题想出一个标题，所以希望这确实有意义。

我将进一步解释。我有一个来自 Excel 文件的数据流，每一行的最后一列都有两个单词之一。它将包含“打开”或“当前”。

所以假设我有一个看起来像这样的输入：

而且目标是只抢一个人一次。每个人都有他们唯一的 ID 作为他们的 SSN。如果两者都存在并且为那个人存在，我想抓住Open行。如果仅存在，则抓住它。所以最终的输出应该是这样的：OpenCurrentCurrent

注意：如您所见，第一个条目John已被删除，因为他有Open一行。

我已经尝试过了，但它很草率，我认为必须有更好的方法。这是我所做的图片： Talend flow

我目前正在开发一个 DevOps 流程，其目标是在将任务从一个环境提升到另一个环境的情况下，使用 Rest Talend API 触发提升管道的执行。

在 API 文档https://api.eu.cloud.talend.com/tmc/swagger/swagger-ui.html#/promotions32585832executions中没有关于任务的 ** artifactType ** 字段的信息。

在研究的过程中，我发现推广人工制品的关键词是 ACTION。但是，不幸的是，我对用于推广任务的关键字没有答案。我已经尝试过 TASK、JOB、STEP 和 ACTION，但它在 json 中显示了一个错误。

如果有人知道在 API Rest 中使用什么关键字来推广任务，那将对我有很大帮助！

谢谢 :)