我已将 Citus 中的 replicaton_factor 设置为 2,因此每个节点都有所有数据,以防万一一个节点发生故障(脱机),我仍然可以获得所有数据。
我遇到的问题是:我不知道如何在使用 INSERT 或 UPDATE 并将数据添加到数据库时失败的节点内部获取数据?我有两个节点和一个协调器,所以基本上在 Node1 下线之后,我将数据添加到 DB Node2 得到了数据。现在我需要将该数据/分片同步到 Node1,因为此时 Node1 基本上没用。
我已将 Citus 中的 replicaton_factor 设置为 2,因此每个节点都有所有数据,以防万一一个节点发生故障(脱机),我仍然可以获得所有数据。
我遇到的问题是:我不知道如何在使用 INSERT 或 UPDATE 并将数据添加到数据库时失败的节点内部获取数据?我有两个节点和一个协调器,所以基本上在 Node1 下线之后,我将数据添加到 DB Node2 得到了数据。现在我需要将该数据/分片同步到 Node1,因为此时 Node1 基本上没用。
找到答案:这是通过 master_copy_shard_placement https://citus-doc.readthedocs.io/en/latest/develop/api_udf.html#master-copy-shard-placement企业不需要。