监控

全量监控：

$ curl -s 127.0.0.1:9341/progress | python -m json.tool
{
    "collection_metric": { // 这个map下面的是单个表的进度
        "Film": "100% (0/0)",
        "Music": "100% (2/2)",
        "MusicCollection": "100% (0/0)",
        "MusicCollection2": "100% (0/0)",
        "look": "100% (7/7)",
        "look2": "100% (5/5)",
        "test2": "100% (2/2)",
        "xxx": "100% (1/1)",
        "zz2": "100% (1/1)"
    },
    "finished_collection_number": 9,
    "processing_collection_number": 0,
    "progress": "100.00%", // 整体进度，已经同步的表个数/整个表的个数
    "total_collection_number": 9,
    "wait_collection_number": 0
}

增量监控：

$ curl -s 127.0.0.1:9340/metric | python -m json.tool
{
    "records_get": 96275, // 拉取的总文档数
    "records_write": 96275, // 写入的总文档数
    "checkpoint_times": 3854, // 内部自增计数，每执行一条写入语句加1
    "checkpoint_update_times": {
        "test_nimoshake": {
            "shardId-00000001611800967759-f5e6c930": {
                "update_time": "2021-01-28T13:05:03Z", // 更新checkpoint的时间
                "sync_approximate_time": "2021-01-28 05:03:55 +0000 UTC", // 最后一条同步的records的大约时间（从dynamodbStreams Record中解析）
                "father_shard_id": "shardId-00000001611787245534-dd2e3968"
            }
        }
    },
    "error": ""
}