更新 aerospike 中所有记录的 ttl

Question

我陷入了将默认 ttl 初始化为 30 天的同名 apce 的情况。大约有 500 万个数据具有该（30 天计算的）ttl 值。实际上，我的要求是 ttl 应该是零 （0），但它（ttl-30d） 保持为不知道或无法识别。

所以，现在我想用新的 ttl 值（零）更新上（旧的）500 万数据。

我已经检查/尝试了“设置禁用逐出 true”，但它不起作用，它正在根据（旧）ttl 值删除数据。

我该如何克服这个问题？（我想检索已删除的数据，我该怎么做？

有人帮我。

Answer 1

如果您有更复杂的逻辑、过滤器等，使用 Python 脚本会更容易。

zero_ttl_operation = [operations.touch(-1)]
query = client.query(namespace, set_name)
query.add_ops(zero_ttl_operation)
policy = {}
job = query.execute_background(policy)
print(f'executing job {job}')
while True:
    response = client.job_info(job, aerospike.JOB_SCAN, policy={'timeout': 60000})
    print(f'job status: {response}')
    if response['status'] != aerospike.JOB_STATUS_INPROGRESS:
        break
    time.sleep(0.5)

Aerospike v6 和 Python SDK v7。

Answer 2

首先，逐出和过期是两种不同的机制。可以通过多种方式禁用逐出，例如已使用的设置禁用逐出配置参数。您无法禁用过期记录的清理。有一个很好的知识库常见问题解答什么是过期、逐出和停止写入？。不幸的是，如果其无效时间是过去，则已清理的过期记录将消失。如果这些记录只是被逐出（即由于跨越内存或磁盘的命名空间高水位线，在其无效时间之前被删除），您可以冷重启节点，并且那些具有未来 TTL 的记录将返回。如果它们被持久删除或它们的 TTL 是过去的（此类记录被跳过），它们将不会返回。

至于重置 TTL，最简单的方法是通过记录 UDF 执行此操作，该记录 UDF 使用扫描应用于命名空间中的所有记录。

适合您情况的 UDF 非常简单：

啧啧.lua

function to_zero_ttl(rec)
  local rec_ttl = record.ttl(rec)
  if rec_ttl > 0 then
    record.set_ttl(rec, -1)
    aerospike:update(rec)
  end
end

在 AQL 中：

$ aql
Aerospike Query Client
Version 3.12.0
C Client Version 4.1.4
Copyright 2012-2017 Aerospike. All rights reserved.
aql> register module './ttl.lua'
OK, 1 module added.

aql> execute ttl.to_zero_ttl() on test.foo