python - Aerospike 通过 TTL 计算所有过滤器

Question

我正在尝试执行以下查询:

SELECT COUNT(*) FROM ns123.foo WHERE ttl < 60 * 60 * 24

我从 Aerospike AQL count(*) SQL analogue script 找到了 lua 脚本执行 COUNT(*)

将 Python 与上述 LUA 脚本结合使用，我尝试应用具有读取策略的 UDF:

        client.udf_put('aggr_functions.lua')
        query = client.query('ns123', 'foo')
        policy = {
            'expressions':
                exp.LT(exp.TTL(), 60 * 60 * 24).compile()
        }
        query.apply('aggr_functions', 'count_star', [])
        records = query.results(policy)
        print(records)

我被抛出:

Traceback (most recent call last):
  ...
    records = query.results(policy)
exception.UnsupportedFeature: (16, 'AEROSPIKE_ERR_UNSUPPORTED_FEATURE', 'src/main/aerospike/aerospike_query.c', 348, False)

对 Python3.8 库和服务器使用 Aerospike 6.1.x。

Answer 1

聚合不支持过滤表达式。但是你可以在 lua 中编写过滤器代码，在 lua 聚合模块本身中添加过滤器功能。 (我在这里发布了一个在 lua 中使用带聚合的过滤器的代码示例:https://discuss.aerospike.com/t/record-manipulation-with-more-than-one-filter-lua/3637)