Aerospike python 客户端:检查记录是否成功存储在集群上

Aerospike python client: check if records were stored on the cluster successfully

我正在开发 Aerospike python 客户端。我正在使用 aerospike 加载程序将数据插入集群。现在我需要查看记录是否成功存储到集群上。

正在使用的命令:

command = 'java -cp /aerospike-loader/aerospike-load-2.2-jar-with-dependencies.jar ' \
              '-Dlog4j.configuration=file:/aerospike-loader/log4j.properties ' \
              'com.aerospike.load.AerospikeLoad -h %s -p %d -n %s -c %s %s'
command_str = command % (self.host, self.port, self.namespace, tmp_json_file.name, data_file_path)

文件 tmp_json_file 包含与此完全相似的配置文件内容:https://www.aerospike.com/docs/tools/asloader/examples.html

现在如何查看数据是否传输成功?我尝试使用 client.exists(key),但未设置 meta 字段 returns None 作为 writePolicy=true。如何使用 python 客户端任何示例进行设置?或任何其他方式来检查记录是否已成功插入?

您可以从 JSON 中提取所有键,并且对于每个 assemble 一个 (namespace, json-set, json-key) 的元组(我的意思是使用 setkey每个 JSON 对象的字段)。然后,您可以使用 aerospike.Client.exists_many 通过批量读取操作来验证密钥的存在。

即使您没有存储人类可读的密钥(这是默认行为,您可能不想花费额外的存储空间),每个 record 都有一个唯一的 20B 摘要。该摘要是通过散列上述 3 元组的集合和主键部分在客户端创建的。当您检查是否存在时,客户端将再次散列您提供的那些密钥,获得相同的摘要,并检查它们是否存在。