技术参考

使用 Snowflake 活动

提示：

本页包含在您使用 Snowflake 活动时可能有用的一些提示。

• 当您预计查询将产生大量行集时，请始终使用LIMIT和OFFSET来对结果进行分页。有关此用例的查询示例，请参阅 Snowflake 文档。
• “生成输出架构”仅适用于不包含任何工作流变量的查询语句。生成输出架构后，您可以将查询替换为变量。我们建议使用您能够直接在 Snowflake 中成功运行的查询。
• 对于需要花费超过 30 秒才能执行的任何查询，请使用“异步执行任何查询” 。
• 您只能使用异步执行任何查询活动执行非选择命令（例如插入、更新、存储过程等）。
• 结合使用获取异步查询执行状态和从异步执行任何查询的输出中获取的查询 ID。
• 在成功执行查询或遇到错误时，您可以使用异步查询状态已更改触发器启动流程。
• 要获取异步查询的结果，请使用“获取异步查询执行状态” 。使用“异步执行任何查询”的输出中的查询 ID 生成输出架构。生成架构后，您就可以使用变量查询 ID。更改变量的输入不会影响输出属性，这些属性保持不变。这意味着除非手动重新生成，否则无法更改生成的输出。我们建议根据需要设置不同的工作流流程。如果您使用的是 Studio 桌面版，则可以使用 Snowflake 包版本 5.0.1 中的“原生搜索”活动。
• 为使“已创建记录”和“已更新记录”触发器成功运行，您必须在要监控事件的表格上执行以下查询： ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE; 。此外，请确保您在 Snowflake 中配置了所需的权限。

在 Snowflake 中插入行时识别主键输出

如果您有一张包含自动递增 ID 列的表格，一个常见的用例是想要在该表格中插入一行并输出所创建行的 ID。

要解决此问题，最简单的方法是在要卸载数据的表中维护外键关系。在下面的示例中，您可能会发现在 “Snowflake插入记录”活动中，即使您有 “输出” SNOWFLAKE_ID ，添加行时的执行期间也没有实际输出。这是 Snowflake 的限制。因此，我们为此表维护一个外键列 ( SFDC_OPPORTUNITY_ID )。

添加行后，我们可以使用“Snowflake原生搜索”活动来查询主键 ( SNOWFLAKE_ID )，以换取外键 ( SFDC_OPPORTUNITY_ID )，并使用后续的“获取行项目”系统活动。

返回的 SNOWFLAKE_ID （主键）也可以存储在上游应用程序（在本例中为 Salesforce）的自定义字段中，以便每次需要对行执行更新时，不需要查询 ID使用外键。