问题标签 [aerospike-ce]

我正在使用 Aerospike 4.8v 并将我的数据保存在磁盘上，并且我正在向 aerospike 发出并行写入请求，如果我发出 10 个并行请求，那么它工作正常，但是当我发出 100 个并行请求时它会给出错误，即此时不允许操作，使用代码 22。我认为 aerospike 必须能够并行处理数百或数千个请求，但我不知道出了什么问题，所以如果有人可以指导这将是有帮助的。

错误日志：

警告日志：

我正在使用 aerospike v4.8，我正在向 aerospike 发出读写请求，在我的写入请求中，我获得了 4000 次写入/秒的吞吐量，而在读取中，吞吐量仅为 10-15 次读取/秒，这是非常低的。

我的查询是：

无法理解这里出了什么问题，需要帮助。

我的配置是：

索引是：

使用以下代码在 Aerospike 中加载数据。data 是 BinMap 类型的地图列表

加载几条记录后，收到以下错误消息。

对于每次迭代，分区测试编号都会更改。即使在每个 Put 命令后等待 5 秒后，该错误仍然存​​在。我不确定错误消息中报告了什么超时。go 客户端需要什么客户端配置？

使用 MacOs 10.15.3；去客户端；Aerospike 在 docker 2.2.0.3 上运行

我想避免使用 Aerospike 客户端（例如用于 Python）并使用本机asinfo命令“截断”从集合中删除记录，因为它可以快速完成。但是在我重新启动 Aerospike 后，所有删除的记录都回来了。我看到了这个aerospike: delete all record in a set但它没有回答我的问题。AS 文档中的此页面也没有。它说，应该在持久删除之后写入墓碑，我必须手动创建它还是有其他方法？

UPD： 感谢@kporter，他在下面提供了接受的答案，我能够研究 Aerospike 的社区版和企业版之间的差异，并找到有关该问题的更多信息，有些人可能会发现它也很有帮助：

• 持久删除[社区版]
• 这个答案和来自 AS 论坛的整个讨论
• 而这个线程

如果我正确理解了所有这些，那么在 CE 中完全删除您的记录的最佳方法是确保它们具有正确的 TTL 并且可以自然过期。如果由于某种原因你有很多没有 TTL 的旧记录，就像我的情况一样，你可以通过 asinfo 发出 truncate 命令，并且在 SSD 上的数据最终被覆盖之前不要重新启动 AS 服务器。或者只是在每次重新启动时用旧记录截断集合。

另外我想知道是否可以完全擦除 AS 存储，然后作为紧急措施从已经截断的数据的备份中恢复它？

UPD1： 因此，我能够使用 Aerospike 存储擦除 SSD，并从备份中仅恢复需要的记录。这是我的做法：

• 首先，您需要通过 asinfo 和 truncate 命令从集合中删除旧记录，文档链接在上面
• 然后使用asbackup备份要保存的命名空间
• 停止你的 AS 服务器，我的在 Docker 容器中，所以我刚刚停止了所说的容器
• 将用作 AS 存储的磁盘清零，我的是 /dev/sdb
• 在此磁盘上创建必要的分区
• 启动 AS 服务器
• 使用arestore从备份中恢复数据

有用的链接：如何删除和清理 aerospike 服务器安装，关于 SSD 设置的 AS 文档

我不确定这对于大型生产设置是否是一个好的解决方案，但它在我的情况下按预期工作，只有一个 AS 节点并且有机会停止它一段时间。通过这种方式，我能够将我的 AS 中的数据大小从 160Gb 减少到 11Gb，因此我的服务器现在只需半小时即可完全重启，而不是像以前那样大约 8 小时。

是否可以使用主键和辅助键。我想根据主键获取所有记录，然后对其应用二级索引？这是正确的方法还是应该使用其他方法？

我有一个带主键的垃圾箱。一旦我使用主键获取记录，我只想获取记录的子集。下面是记录示例。还有没有更好的方法来组织记录？比如以经理、主管等人员为key，然后查询。

链接如下：- https://www.aerospike.com/blog/spring-data-for-aerospike/

我们有以下示例实体：-

使用 Spring 存储库，我们使用以下方法：-

// 工作 List<Customer> findByMobileNumber (String mobileNumber);

// 失败，201 ERR INNDEX NOT FOUND。 List<Customer> findByMobileNumberAndCustType (String mobileNumber, String customerType);

事实/观察：-

1.) 我们没有在我们的 aerospike-set 上创建任何明确的二级索引。

2.) 当我们使用 AQL 查询（select * from test.cust where mobileNumber = '981XXXXXXX'）相同的记录时，它失败给我们一个 Indices not found 的错误。

疑虑/问题：-

a.) 第一种方法是如何工作的？它执行的内部方式是什么？查询完成后是否有任何即时创建并被冲走的二级索引？

b.) 为什么第二个失败了？

任何回应都将受到高度赞赏！

用例：-

我们正在使用 Spring-data-aerospike 来获取和设置 aerospike 记录。同时，我们有多个 Kafka 消费者试图更新单个记录的不同字段。

问题：- 我们正面临着 Dirt-read 问题的挑战。记录正在被覆盖。

这里的问题是：Consumer-2 更新的 'custType' 值在 t=4 时丢失了。

这是代码片段的样子：-

这是依赖项的样子：-

问题 ：-

我们知道 spring 事务与 RDBMS 一起工作！在这种情况下让事务性属性在这里工作的方法是什么？

任何帮助或建议将不胜感激！

我们有以下 aerospike 设置配置，并希望地图中的条目应在“x”天后自动删除。应该如何使用 Spring data aerospike 来实现相同的目标？

此外，我的地图中有大约 10 - 12 个 <K,V> 对，每个具有不同的结构，我只希望 1 个特定的 <K,V> 在 x 天后过期！

依赖项看起来像： -

我们有以下 aerospike 数据模型@prod。我们仅依靠 Aerospike 作为我们的数据中心。现在，我们需要为销售团队生成每小时报告：报告详细说明每小时获得的客户数量。

疑虑需要帮助：-

a.) 如何通过避免次要指数来达到同样的效果！我们没有任何关于生产的二级索引，并且希望避免使用它们。

b.) 有没有一种方法可以生成上述类型的报告，因为我们没有 MYSQL / RDBMS 复制下面的数据！

c.) 频繁的 aerospikeSET扫描是否会导致性能下降？

用例：-

我们正在使用 Spring-data-aerospike 来获取并保存 aerospike 记录。

问题：- 我们在两个不同的 aerospike 集合中执行 SAVE，这两个 SAVE 都应该以事务方式发生，即如果第二次写入失败，那么第一次写入也应该回滚。

这是代码片段的样子：-

这是我们想要实现的目标，但现在不起作用：-

这是依赖项的样子：-

问题 ：-

我们知道 Spring 事务注释可与 RDBMS 一起使用！在这种情况下让事务性属性在这里工作的方法是什么？

任何帮助或建议将不胜感激！