Elasticsearch按年度汇率查询的方案优化技术咨询

完全可以实现你的需求！这个场景正好能发挥Elasticsearch处理参考数据关联查询的优势，还能彻底解决原方案的存储冗余和批量更新痛点。下面是几个经过验证的最优实践：

方案1：单独维护汇率索引，查询时动态关联（基础版） #

首先，咱们新建一个专门存年度汇率的索引exchange_rates，结构极简：

PUT /exchange_rates
{
  "mappings": {
    "properties": {
      "year": {"type": "integer"},
      "usd_rate": {"type": "double"},
      "eur_rate": {"type": "double"}
    }
  }
}

然后把各年度的汇率数据存进去，比如2023年的记录：

POST /exchange_rates/_doc/2023
{
  "year": 2023,
  "usd_rate": 7.2,
  "eur_rate": 7.8
}

接下来，在查询财务数据时，用Painless脚本的indices.get方法动态拉取对应年度的汇率，计算转换后的营收：

GET my_index/_search
{
  "query": {
    "nested": {
      "path": "profitsAndLosses",
      "query": {
        "script": {
          "script": {
            "lang": "painless",
            "source": """
              // 提取当前记录的年度和本币营收
              def report_year = doc['profitsAndLosses.yearReport'].value;
              def local_revenue = doc['profitsAndLosses.revenue'].value;
              
              // 从汇率索引拿对应年度的汇率（用年份做文档ID，查询更快）
              def rate_doc = indices.get({
                "index": "exchange_rates",
                "id": String.valueOf(report_year)
              });
              
              // 转换成USD营收（要查EUR就换成eur_rate）
              def converted_revenue = local_revenue / rate_doc['_source']['usd_rate'];
              
              // 判断是否在目标区间
              return converted_revenue >= params.from && converted_revenue <= params.to;
            """,
            "params": {
              "from": 1000,
              "to": 2000
            }
          }
        }
      }
    }
  }
}

这个方案的好处：

• 彻底干掉存储冗余，汇率只存一份
• 更新汇率时，只需要修改exchange_rates里对应年度的文档，再也不用重新索引几百万条财务数据
• 后续加新币种，直接在汇率索引里加字段就行，扩展性拉满

注意点：

• 确保exchange_rates的文档ID和年份一致（比如用2023当ID），这样脚本查询效率最高
• 给执行查询的用户开exchange_rates的访问权限（如果集群有安全控制的话）

方案2：用Runtime Fields预计算外币营收（推荐，效率更高） #

如果需要频繁按外币营收查询，强烈推荐给my_index加Runtime Fields，动态计算USD/EUR营收。这样查询时就能像查本币一样用普通的range，不用写复杂脚本：

先更新my_index的映射，添加两个runtime字段：

PUT /my_index/_mapping
{
  "runtime": {
    "profitsAndLosses.usd_revenue": {
      "type": "double",
      "script": {
        "source": """
          def report_year = doc['profitsAndLosses.yearReport'].value;
          def rate_doc = indices.get({
            "index": "exchange_rates",
            "id": String.valueOf(report_year)
          });
          emit(doc['profitsAndLosses.revenue'].value / rate_doc['_source']['usd_rate']);
        """
      }
    },
    "profitsAndLosses.eur_revenue": {
      "type": "double",
      "script": {
        "source": """
          def report_year = doc['profitsAndLosses.yearReport'].value;
          def rate_doc = indices.get({
            "index": "exchange_rates",
            "id": String.valueOf(report_year)
          });
          emit(doc['profitsAndLosses.revenue'].value / rate_doc['_source']['eur_rate']);
        """
      }
    }
  }
}

之后，外币查询就和本币查询一模一样了：

// USD营收区间查询示例
GET my_index/_search
{
  "query": {
    "nested": {
      "path": "profitsAndLosses",
      "query": {
        "range": {
          "profitsAndLosses.usd_revenue": {
            "gte": 1000,
            "lte": 2000
          }
        }
      }
    }
  }
}

这个方案的优势：

• 查询语法和本币完全一致，开发维护成本极低
• Runtime Fields是动态计算的，不占额外存储，汇率更新后立即生效
• 性能比脚本查询好太多，ES会自动缓存计算结果

方案3：把汇率作为查询参数传入（适合汇率极少变动的场景） #

如果你的汇率几年才变一次，也可以直接把年度汇率作为参数传到脚本里，不用额外维护索引：

GET my_index/_search
{
  "query": {
    "nested": {
      "path": "profitsAndLosses",
      "query": {
        "script": {
          "script": {
            "lang": "painless",
            "source": """
              // 根据年度匹配对应的汇率
              def rate = params.rates[doc['profitsAndLosses.yearReport'].value];
              def converted_revenue = doc['profitsAndLosses.revenue'].value / rate;
              return converted_revenue >= params.from && converted_revenue <= params.to;
            """,
            "params": {
              "from": 1000,
              "to": 2000,
              "rates": {
                2020: 7.0,
                2021: 6.5,
                2022: 7.1,
                2023: 7.2
              }
            }
          }
        }
      }
    }
  }
}

这个方案最容易实现，但缺点是每次汇率变动都要改查询参数，适合汇率几乎不变的场景。

总结下来，**方案2（Runtime Fields + 汇率索引）**是最优选择，兼顾了查询效率、维护便捷性和扩展性，完美解决你原方案的所有问题。

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