同一Azure ADX集群跨数据库基于源表更新的数据摄入问题

针对同一Azure ADX集群中，配置跨库更新策略时提示Source table does not exist的问题，可通过以下步骤排查解决：

1. 修正查询函数的源表引用 #

更新策略执行时默认以目标数据库为上下文，若QueryFunction()内部未明确指定源数据库，会默认在目标库DataBase2中查找表，导致找不到SourceTable。

• 修改函数定义，将源表引用改为完整的数据库限定格式：

  .create function QueryFunction() {
      DataBase1.SourceTable
      // 后续数据处理逻辑
  }
  

2. 配置Source参数的完整集群限定名 #

即使是同一集群，更新策略的Source参数要求使用集群.数据库.表的完整格式，不能仅写数据库.表。可通过两种方式指定：

• 直接写集群名称：

  .alter table DataBase2.ChildTable policy update
  '''
  [
      {
          "IsEnabled": true,
          "Source": "YourClusterName.DataBase1.SourceTable",
          "Query": "QueryFunction()"
      }
  ]
  '''
  

• 使用.current_cluster()函数自动获取当前集群：

  .alter table DataBase2.ChildTable policy update
  '''
  [
      {
          "IsEnabled": true,
          "Source": ".current_cluster().DataBase1.SourceTable",
          "Query": "QueryFunction()"
      }
  ]
  '''
  

3. 验证权限配置 #

确保执行策略的身份（包括手动配置的账号和ADX系统执行账号）对DataBase1.SourceTable有读取权限：

• 登录DataBase1，为目标主体分配Data Viewer或Viewer角色：

  .add database DataBase1 viewers ('aaduser=xxx@xxx.com' or 'aadapp=xxx')
  

  注：ADX系统执行账号格式为aadapp=<集群的系统应用ID>，可通过.show cluster identity查询获取。

4. 检查语法转义问题 #

确保配置语句中的JSON引号正确，避免使用HTML转义符（如"）。在Kusto工具中使用三重单引号包裹JSON时，直接使用普通双引号即可。

验证策略有效性 #

配置完成后，可通过以下命令确认策略状态：

.show table DataBase2.ChildTable policy update

也可手动触发更新测试，排查是否仍有报错：

.execute table DataBase2.ChildTable policy update

内容的提问来源于stack exchange，提问作者William D'Alessandro