使用Dapr QueryStateAsync查询状态存储失败：查询索引未找到

使用Dapr客户端从Redis/Cosmos检索JSON格式数据时，通过Key调用daprClient.GetStateAsync("StateStore", Key)可正常获取数据，但调用QueryStateAsync按值过滤时抛出错误：

Grpc.Core.RpcException: Status(StatusCode="Internal", Detail="failed query in state store statestore: query index not found")

初始查询代码：

var query = "{" +
"\"filter\": {" +
"\"EQ\": { \"ValueNode\": \"" + value+ "\" }" +
"}}";
daprClient.QueryStateAsync("StateStore",query ) // 无法正常工作

尝试在statestore.yaml配置查询索引后问题仍未解决：

- name: queryIndexes
    value: |
      [
        {
          "name": "ValueRefIndex",
          "indexes": [
            {
              "key": "ValueRef",
              "type": "TEXT"
           }
          ]
        }
      ]

调整后的查询代码：

CancellationTokenSource source = new CancellationTokenSource();
CancellationToken cancellationToken = source.Token;
Dictionary<string, string> metadata = new() { { "contentType", "application/json" }, { "ValueRefIndex", "ValueRef" } };

var query = "{" +
        "\"filter\": {" +
            "\"EQ\": { \"ValueRef\": \"" + ValueRef+ "\" }" +
        "}}";

var queryResponse = await daprClient.QueryStateAsync<Product>(DaprStateStore, query);

针对不同状态存储（Redis/Cosmos），需分别调整配置和代码：

一、Redis作为状态存储的情况 #

1. 确认Redis版本支持RediSearch
   Dapr的Redis状态存储查询依赖RediSearch模块，需确保Redis实例已安装并启用该模块（使用Redis Stack则默认包含）。

2. 修正索引配置格式
   statestore.yaml中queryIndexes的配置需严格符合Dapr规范，注意缩进和字段完整性：

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.redis
  version: v1
  metadata:
  - name: redisHost
    value: "localhost:6379"
  - name: redisPassword
    value: ""
  - name: queryIndexes
    value: |
      [
        {
          "name": "ValueRefIndex",
          "indexes": [
            {
              "key": "ValueRef",
              "type": "TEXT"
            }
          ]
        }
      ]

配置完成后必须重启Dapr sidecar，确保索引生效。

3. 修正查询代码

• 避免手动拼接JSON，改用匿名对象序列化生成查询语句，减少语法错误：

using System.Text.Json;

var queryObj = new
{
    filter = new
    {
        EQ = new { ValueRef = ValueRef }
    }
};
string query = JsonSerializer.Serialize(queryObj);

// 无需在metadata中传递索引名称，Dapr会自动匹配配置的索引
var queryResponse = await daprClient.QueryStateAsync<Product>("StateStore", query);

二、Cosmos DB作为状态存储的情况 #

1. 在Cosmos端配置索引
   Dapr的Cosmos状态存储查询依赖Cosmos容器自身的索引策略，需在Azure门户的目标Cosmos容器中配置对应字段的索引规则，示例：

{
    "indexingMode": "consistent",
    "automatic": true,
    "includedPaths": [
        {
            "path": "/ValueRef/?",
            "indexes": [
                {
                    "kind": "Range",
                    "dataType": "String",
                    "precision": -1
                }
            ]
        }
    ]
}

2. 移除Dapr组件中的queryIndexes配置
   Cosmos DB无需在Dapr的statestore.yaml中配置queryIndexes，直接删除该配置项即可。

3. 修正查询代码
   同样使用序列化方式生成查询语句，避免手动拼接：

using System.Text.Json;

var queryObj = new
{
    filter = new
    {
        EQ = new { ValueRef = ValueRef }
    }
};
string query = JsonSerializer.Serialize(queryObj);

var queryResponse = await daprClient.QueryStateAsync<Product>("StateStore", query);

通用排查步骤 #

• 查看Dapr sidecar日志，获取更详细的错误细节，定位索引未找到的具体原因
• 检查状态存储中已存数据的结构，确认ValueRef字段存在且格式正确
• 验证Dapr组件配置文件的语法正确性（如YAML缩进、JSON格式）

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