查询 MongoDB--SPL 轻量级多源混算实践 4

除了以上常见数据源，还有 NoSQL、MQ 等数据源，其中以 MongoDB 最为常用。我们用 SPL 连接 MongoDB 做计算。

导入 MongoDB 数据。

外部库

SPL 支持的多种数据源大概分两类，一类是像 RDB 有 JDBC 直接使用，或者文件等直接读取；另一类是像 MongoDB 等非关系数据源是在官方驱动上进行了简单封装，具体以“外部库”的形式提供。

外部库列表包括以下数十种非常规数据源及函数：

外部连接器放在外部库中，外部库是 SPL 提供的外部函数扩展库，将一些在普遍场景使用频率不高的专门用途函数以外部库形式提交，这样可以根据需要临时加载。

外部数据源种类繁多，也不是每种数据源都很常用，所以将这些连接器以外部库的形式提供会更为灵活，以后发现有新的数据源也可以及时补充而不影响现有的数据源。

具体使用时，需要先下载外部库驱动：https://download.raqsoft.com.cn/esproc/ext/extlib/extlib-20250508.zip

然后放置到任意目录，比如 [安装目录] \esProc\extlib。接着在 IDE 中加载外部库目录，并勾选要用到的外部库。

计算用例

Orders 集合存储了订单相关信息，其结构和内容如下：

{
  "_id": {
    "$oid": "6826ade0cbc0428d8335b0bb"
  },
  "order_id": "ORD1001",
  "customer": "C001",
  "order_date": {
    "$date": "2025-01-15T00:00:00.000Z"
  },
  "order_details": [
    {
      "product_id": "P001",
      "product_name": "Laptop",
      "quantity": 1,
      "price": 899.99
    },
    {
      "product_id": "P005",
      "product_name": "Wireless Mouse",
      "quantity": 2,
      "price": 19.99
    }
  ]
}

现在要查询：orders 集合中订单金额前 3 的客户

SPL 脚本：

A1：连接 MongoDB

A2：查询 orders 数据，@d 表示返回成序表。

这是一个多层结构，其中一个 order_details 展开，与之前处理的 JSON 结构是类似的。

A2 执行的命令完全是 MongoDB 的原生语法，我们在 MongoShell 中执行看：

成功返回了游标。取出 1 条看看：

A3：按客户分组汇总订单金额，后续的计算就都一样了。

A4：使用 top 函数取前 3 大客户

我们再做个过滤，查询 2025-02-01 之前的订单。

A2 改成：

=mongo_shell@d(A1,"{'find':'orders',filter: {order_date: { $lt: new ISODate('2025-02-01T00:00:00Z') } }}")

运行结果：

在 MongoDB 中执行同样的命令，可以得到相同的结果。

这里以 MongoDB 来举例说明 SPL 连接特殊数据源时的处理方式。其他数据源也是类似配置外部库，然后使用对应的原生语法访问即可。

比如读取 Kafka 数据：

访问 Elasticsearch：

访问 HDFS：

SPL 这种 Native 接口 + 简单封装的方式简单方便，可以保留数据源的特点，充分利用其存储和计算能力，不需要先把数据做“某种”入库动作，实时访问就可以；用户想要扩展也不难。但读数是写在 SPL 脚本里的，而且使用了原生接口，这就意味着如果数据源变化时还要修改脚本，没法做到像逻辑数仓那样对底层数据源完全透明。

逻辑数仓的数据源接入依赖的专用连接器，可以做到完全对底层透明。但连接器要针对每种数据源单独开发，复杂度很高，导致可用 Connector 数量明显不多，用户自行基于开源代码再开发的难度也很大，往往要等厂商支持。

逻辑数仓专用 Connector 和 SPL 使用 Native 接口简单封装没有好坏之分，前者可以做更深层次的支持和优化，可以做到一定程度的透明化；后者则更加灵活，支持的数据源丰富且扩展灵活，要根据具体需要选择。

至此我们已经学会了用 SPL 查询数据库、CSV/XLS、Restful/JSON、MongoDB，这些数据接入后都可以进行混合计算了。