一、源端
    1、ConsumerKafka

    1. @param hostList
    2. @param topicName
    3. @param groupId

    2、JoltTransformJSON

    1. @param jolt transform
      1. 宁夏
        1. 单条Json解析规则示例： ```json // 实际数据 { “goldenId”:1603782, “pointTime”:”2022-01-07 16:06:22”, “tagName”:”QSFJ.NX_GD_QSF_FJ_P1_L3_032_AI0002”, “valueDouble”:1.600000023841858, “valueInt”:0, “valueType”:”Double” }

    // 解析规则 [{ “operation”: “shift”, “spec”: { “pointTime”: “pointTime”, “valueDouble”: “valueDouble”, “tagName”: “tagName” } }]

    // 解析结果 { “pointTime”: “1970-01-01 00:00:00”, “valueDouble”: 1.0, “tagName”: “GDNXFD_P1_L1_A0921” }

    2.       2. 列表Json模式解析示例：
    3. ```json
    4. // 实际数据
    5. {
    6.   "dataCount":29,
    7.   "data":[
    8.     {
    9.       "key": "AAAAAAA",
    10.       "dataType": 10,
    11.       "time": "2021-01-01 00:00:00",
    12.       "data":66.983154296875
    13.     },{
    14.       "key":"BBBBBBB",
    15.       "dataType":10,
    16.       "time":"2021-01-01 00:00:01",
    17.       "data":66.91868591308594
    18.     }
    19.   ]
    20. }
    22. // 解析规则
    23. [{
    24.     "operation": "shift",
    25.     "spec": {
    26.         "data": {
    27.           "*": {
    28.             "time": "result[#2].pointTime",
    29.             "data": "result[#2].valueDouble",
    30.             "key": "result[#2].tagName"
    31.           }
    32.         }
    33.     }
    34. }]
    36. // 解析结果
    37. {
    38.   "result": [
    39.     {
    40.       "pointTime": "2021-01-01 00:00:00",
    41.       "valueDouble": 66.983154296875,
    42.       "tagName": "AAAAAAA"
    43.     },
    44.     {
    45.       "pointTime": "2021-01-01 00:00:00",
    46.       "valueDouble": 66.91868591308594,
    47.       "tagName": "BBBBBBB"
    48.     }
    49.   ]
    50. }
    1.   3. othre
    1. [{
    2.  "operation": "shift",
    3.  "spec": {
    4.   "Result": {
    5.    "*": {
    6.     "*": {
    7.   "$1": "&2[#2].tagName",
    8.      "Time": "&2[#2].pointTime",
    9.      "Value": "&2[#2].valueDouble"
    10.     }
    11.    }
    12.   }
    13.  }
    14. }]
    16. [{
    17.  "operation": "shift",
    18.  "spec": {
    19.   "Result": {
    20.    "*": {
    21.     "TagFullName": "&2[#2].tagName",
    22.     "Time": "&2[#2].pointTime",
    23.     "Value": "&2[#2].valueDouble"
    24.    }
    25.   }
    26.  }
    27. }]

    二、目标端
    1、NIFI Flow
    2、ExecuteGroovyScript

    1. @param TDUrl（必填）
    2. @param DBName（必填）
    3. @param STBName（可选，当且仅当子表已存在）
    4. @param model json的模式（single｜list）

    三、附页
    1、附1页