关于集群部署数据清理的咨询

我去试试，多谢冷老师

一般来说可以清理行记录日志。

https://docs-pd.mingdao.com/deployment/mongodb/command

用这个命令在 mongobd 里查下 mdworksheetlog 库里表的大小，删除比较久以前的日志即可
直接用 db.表名。drop() 就可以把空间清出来了

这个单机版本的清理是否同样适用于集群部署呢

操作清理数据命令前务必提前备份数据！

清理后页面上对应时间段的工作流执行历史记录将没有！

清理时，数据量比较大，可能会比较耗时，建议请在业务空闲时进行操作！

一、清理 code_catch、hooks_catch、webhooks_catch

use mdworkflow
db.getCollection("code_catch").remove({});
db.getCollection("hooks_catch").remove({});
db.getCollection("webhooks_catch").remove({});

二、清理 wf_instance、wf_subInstanceActivity、wf_subInstanceCallback、app_multiple_catch、custom_apipackageapi_catch

清理前先额外对 app_multiple_catch 集合添加索引，已添加过可忽略

db.getCollection("app_multiple_catch").createIndex({ "instanceId": 1 }, {background: true}))

清理命令参考：

如 清理 2022-09-30 的数据

use mdworkflow
​
db.getCollection("wf_instance").find({ "completeDate": { $lte: ISODate("2022-09-30T16:00:00.000Z"), $gt: ISODate("2022-09-29T16:00:00.000Z") } }).forEach(
    function(ref){
      db.getCollection("wf_instance").remove({"_id" :ref._id});
      db.getCollection("wf_subInstanceActivity").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("wf_subInstanceCallback").remove({"_id" :ref._id});
      db.getCollection("app_multiple_catch").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("custom_apipackageapi_catch").remove({"instanceId" :ref._id.valueOf()});
    }
);

如 清理 2022-09-10 至 2022-09-20 的数据

use mdworkflow
​
db.getCollection("wf_instance").find({ "completeDate": { $lte: ISODate("2022-09-20T16:00:00.000Z"), $gt: ISODate("2022-09-09T16:00:00.000Z") } }).forEach(
    function(ref){
      db.getCollection("wf_instance").remove({"_id" :ref._id});
      db.getCollection("wf_subInstanceActivity").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("wf_subInstanceCallback").remove({"_id" :ref._id});
      db.getCollection("app_multiple_catch").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("custom_apipackageapi_catch").remove({"instanceId" :ref._id.valueOf()});
    }
);

如 清理 2022-09-10 及以前的所有数据

use mdworkflow
​
db.getCollection("wf_instance").find({ "completeDate": { $lte: ISODate("2022-09-10T16:00:00.000Z") } }).forEach(
    function(ref){
      db.getCollection("wf_instance").remove({"_id" :ref._id});
      db.getCollection("wf_subInstanceActivity").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("wf_subInstanceCallback").remove({"_id" :ref._id});
      db.getCollection("app_multiple_catch").remove({"instanceId" :ref._id.valueOf()});
      db.getCollection("custom_apipackageapi_catch").remove({"instanceId" :ref._id.valueOf()});
    }
);

比如各种日志，修改记录这些，工作流历史什么的