扩展的微服务实例需要更新 1

Question

我有一个独特的问题，试图看看什么是最好的实现。

• 我的表格有 50 万行。每行代表 我需要从中获取有关该实体的信息的业务实体 互联网并异步更新回表 . （此过程大约需要 2 到 3 分钟）。
• 我无法使用 1 个实例有效地更新所有这些行 微服务。因此计划将其扩展到多个实例
• 我的微服务实例是异步守护进程，每次获取业务实体 1 并处理数据并最终将数据更新回表。 .这是我在多个实例之间的问题我如何确保没有 2 个微服务实例在更新过程中与相同的业务实体（同一行）一起工作？我想实现一个最佳解决方案微服务，可能无需在应用层维护任何状态。

Answer 1

您必须使用外部系统（数据库/缓存）来保存有关每个实例的信息。

例如：Shedlock。在数据库中创建一个表或文档，用于存储有关当前锁的信息。

Answer 2

我建议您使用工作队列。这看起来非常适合您的问题。只需将整个数据或数据的 id 加载到队列中一次。然后让消费者消费。 你可以在这里看到一个清晰的解释 https://www.rabbitmq.com/tutorials/tutorial-two-python.html