如何用Go AWS SDK通过通配符查询DynamoDB嵌套Map中含指定标签的节点？

DynamoDB的表达式语法不支持用通配符（如*或?）遍历Map的键，所以你尝试的nodes.*.tags写法无法生效。以下是两种可行的解决思路：

一、调整数据结构（推荐） #

把nodes从Map改成数组，每个元素包含节点名称和标签列表，结构如下：

{
  "nodes": [
    {"name": "apple", "tags": ["a", "b"]},
    {"name": "orange", "tags": ["b", "c"]}
  ]
}

这种结构下，你可以用DynamoDB的数组遍历表达式直接过滤包含指定标签的项，Go SDK代码示例：

package main

import (
	"context"
	"github.com/aws/aws-sdk-go-v2/aws"
	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
	"github.com/aws/aws-sdk-go-v2/service/dynamodb/expression"
)

func main() {
	// 初始化DynamoDB客户端（此处省略客户端初始化逻辑）
	var dynamodbClient *dynamodb.Client

	// 构建过滤条件：检查nodes数组中是否有元素的tags包含"b"
	filter := expression.Name("nodes[*].tags").Contains(expression.Value("b"))
	expr, err := expression.NewBuilder().WithFilter(filter).Build()
	if err != nil {
		// 处理错误
		return
	}

	// 执行扫描请求
	_, err = dynamodbClient.Scan(context.TODO(), &dynamodb.ScanInput{
		TableName:                 aws.String("your-table-name"),
		ExpressionAttributeNames:  expr.Names(),
		ExpressionAttributeValues: expr.Values(),
		FilterExpression:          expr.Filter(),
	})
	if err != nil {
		// 处理错误
		return
	}
}

二、不调整数据结构的折中方案 #

如果无法修改现有数据结构，只能用以下两种方式：

• 枚举所有节点键：适合节点键固定且数量少的场景，通过多节点OR条件实现，代码示例：

  // 构建多个节点的OR过滤条件
  appleFilter := expression.Name("nodes.apple.tags").Contains(expression.Value("b"))
  orangeFilter := expression.Name("nodes.orange.tags").Contains(expression.Value("b"))
  filter := expression.Or(appleFilter, orangeFilter)
  
  expr, err := expression.NewBuilder().WithFilter(filter).Build()
  // 后续请求逻辑同上
  

• 客户端侧过滤：先执行全表扫描获取所有数据，再在Go代码中遍历nodes的每个键，检查对应tags数组是否包含目标标签。示例：

  // 执行全表扫描
  resp, err := dynamodbClient.Scan(context.TODO(), &dynamodb.ScanInput{
    TableName: aws.String("your-table-name"),
  })
  if err != nil {
    // 处理错误
    return
  }
  
  // 客户端侧筛选符合条件的项
  var matchedItems []map[string]types.AttributeValue
  for _, item := range resp.Items {
    nodesAttr, ok := item["nodes"]
    if !ok || nodesAttr.M == nil {
      continue
    }
    hasTagB := false
    // 遍历nodes下的所有节点
    for _, node := range nodesAttr.M {
      tagsAttr, ok := node.M["tags"]
      if !ok || tagsAttr.L == nil {
        continue
      }
      // 检查tags数组是否包含"b"
      for _, tag := range tagsAttr.L {
        if *tag.S == "b" {
          hasTagB = true
          break
        }
      }
      if hasTagB {
        break
      }
    }
    if hasTagB {
      matchedItems = append(matchedItems, item)
    }
  }
  

  注意：这种方法会读取全表数据，数据量大时性能差、成本高，仅适合小规模数据集。

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