如何使用Azure Logic App将HTTP API响应插入SQL数据库并解决重复插入问题

核心思路是从数据源、数据库、同步流三个层面做幂等性校验，从逻辑到兜底完全避免重复插入问题：

1. 数据源侧取固有唯一标识与变更标记 #

• 直接复用Drupal原生字段：所有Drupal内容实体默认自带nid（单条内容全局唯一ID）和changed（内容最后更新时间戳）两个字段，调用Drupal API时直接同步拉取这两个字段即可，无需额外开发改造Drupal侧逻辑
• 若需要更高精度的内容校验，可以额外对业务内容做MD5哈希生成etag字段，一般场景下nid+changed的组合已足够完成变更判断

2. SQL库侧加约束与校验逻辑 #

• 先做兜底约束：给SQL业务表添加唯一索引，把nid设为唯一键，或把nid+changed设为联合唯一键，就算上层逻辑漏判，数据库本身也会拒绝重复数据写入，避免脏数据
• 写入逻辑改为Upsert（存在则更新、不存在则插入）模式：
  • 每次拉到Drupal内容后，先用nid作为查询条件到SQL表中检索对应记录
  • 无匹配记录：直接插入整条新数据
  • 有匹配记录：对比拉取到的changed时间戳与库中存储的changed值，仅当拉取到的时间戳更新时才执行内容更新操作，时间戳一致则直接跳过写入

3. Azure Logic App同步流改造 #

• 拉取Drupal API内容的动作后，新增「执行SQL查询」动作，查询语句参考：SELECT 1 FROM 你的业务表名 WHERE nid = @{triggerBody()?['nid']} AND changed >= @{triggerBody()?['changed']}
• 新增条件分支：如果上述查询返回结果为空，执行后续写入动作；如果返回结果不为空，直接终止本次同步任务的执行
• 批量拉取内容的场景可以直接用SQL的MERGE语句批量处理，比单条循环判断效率更高，语句参考：

MERGE INTO 你的业务表 AS target
USING (VALUES (@nid, @changed, @业务字段1, @业务字段2)) AS source (nid, changed, col1, col2)
ON target.nid = source.nid
WHEN MATCHED AND source.changed > target.changed THEN
    UPDATE SET col1 = source.col1, col2 = source.col2, changed = source.changed
WHEN NOT MATCHED THEN
    INSERT (nid, changed, col1, col2) VALUES (source.nid, source.changed, source.col1, source.col2);

可选优化项 #

• 给Drupal API请求加增量过滤参数?changed=[上次同步的时间戳]，每次仅拉取上次同步之后新增/更新的内容，减少不必要的校验和IO消耗
• 若业务场景下内容写入后不会更新，可直接把nid设为SQL表的主键，插入时加IF NOT EXISTS判断即可

内容的提问来源于stack exchange，提问作者Varanasi Phaneendra