数据流

数据结构

水滴接收到的结构

{
    "company_name_digest": "主体唯一键",
    "data_type": "动态的维度",
    "change_type": "变化的类型",
    "change_time": "发现变化的时间",
    "content_before": "变化前内容",
    "content_after": "变化后内容",
    "happen_date": "实际发生的日期： 2020-07-01",
    "discover_day_diff": "发现变化日期与实际发生日期相差的天数"
}

或

"{company_name_digest}"

sync_redis模块接收到的结构,topic:collie-sync-redis

{
    "msg": {
        "company_name_digest": "主体唯一键",
        "data_type": "动态的维度",
        "change_type": "变化的类型",
        "change_time": "发现变化的时间",
        "content_before": "变化前内容",
        "content_after": "变化后内容",
        "happen_date": "实际发生的日期： 2020-07-01",
        "discover_day_diff": "发现变化日期与实际发生日期相差的天数"
    },
    "sync_condition": {
        "data_type": "company_change_monitor",
        "operation": "rpush"
    }
}

{
    "msg": "company_name_digest",
    "sync_condition": {
        "data_type": "company_tag_es",
        "operation": "rpush"
    }
}

招聘+知识产权的digest推动

{
    "msg": "company_name_digest",
    "sync_condition": {
        "data_type": "company_tag_es_tmp",
        "operation": "rpush"
    }
}

{
    "sync_status": "success",
    "company_name_digest": "company_name_digest"
}

[
{"sync_status": "success","company_name_digest": "company_name_digest1"},
{"sync_status": "success","company_name_digest": "company_name_digest2"},
{"sync_status": "success","company_name_digest": "company_name_digest3"}
]

数据记录说明