NiFi - JOLT Spec добавить настраиваемое поле - PullRequest
Новая
       10

NiFi - JOLT Spec добавить настраиваемое поле

0 голосов
/ 11 февраля 2019

Мне нужна помощь с JOLT Spec, у меня нет опыта работы с языком выражений JOLT, и чтобы достичь этой точки, чтобы сгладить ответ JSON с JOLT Spec, у меня ушло довольно много времени.

Мне нужно добавитьпеременная, которая НЕ находится в ответе JSON, в моей попытке я использую "dev_id": "TEST HELLO".

Я использую https://jolt -demo.appspot.com / # inception дляпротестируйте JOLT Spec, где я добавляю dev_id ":" TEST HELLO ", но я не могу найти dev_id в выходных данных и нет ошибок по синтаксису.

Заранее спасибо.

Мой ответ JSON выглядит следующим образом: 

{
  "id": 25692584,
  "timestamp": "2018-11-19T07:23:07.022916",
  "notification": "$device-add",
  "parameters": {
    "id": "aa190000-3143-0000-2020",
    "isBlocked": false,
    "name": "aa190000-3143-0000-2020",
    "status": "Online",
    "type": "DOOR",
    "time": "2000-01-01T02:00:39.000000",
    "secure": true,
    "mode": "idle",
    "gps.lat": 24.675699,
    "gps.long": 46.663898,
    "entries": "959,reboot 0x0001",
    "data": {
      "desc": "Undescribed",
      "imei": "861107036",
      "simid": "89564700000"
    },
    "network": {
      "id": 11,
      "name": "TEST",
      "description": null
    },
    "deviceClass": {
      "id": 12,
      "name": "CGM_IOT",
      "version": "2.0",
      "isPermanent": false,
      "offlineTimeout": 60,
      "data": null,
      "equipment": []
    }
  }
}

Затем я использую следующую спецификацию JOLT: 

[
  {
    "operation": "shift",
    "spec": {
      "*": "&",
      "parameters": {
        "*": "parameters-&",
        "data": {
          "*": "data-&"
        },
        "network": {
          "*": "network-&"
        },
        "deviceClass": {
          "*": "deviceClass-&"
        }
      }
    }
    }
]

И получаю следующий вывод: 

{
  "id" : 25692584,
  "timestamp" : "2018-11-19T07:23:07.022916",
  "notification" : "$device-add",
  "parameters-id" : "aa190000-3143-0000-2020",
  "parameters-isBlocked" : false,
  "parameters-name" : "aa190000-3143-0000-2020",
  "parameters-status" : "Online",
  "parameters-type" : "DOOR",
  "parameters-time" : "2000-01-01T02:00:39.000000",
  "parameters-secure" : true,
  "parameters-mode" : "idle",
  "parameters-gps.lat" : 24.675699,
  "parameters-gps.long" : 46.663898,
  "parameters-entries" : "959,reboot 0x0001",
  "data-desc" : "Undescribed",
  "data-imei" : "861107036",
  "data-simid" : "89564700000",
  "network-id" : 11,
  "network-name" : "TEST",
  "network-description" : null,
  "deviceClass-id" : 12,
  "deviceClass-name" : "CGM_IOT",
  "deviceClass-version" : "2.0",
  "deviceClass-isPermanent" : false,
  "deviceClass-offlineTimeout" : 60,
  "deviceClass-data" : null,
  "deviceClass-equipment" : [ ]
}

То, что я пробовал в спецификации JOLT: 

[
  {
    "operation": "shift",
    "spec": {
      "*": "&",
      "dev_id": "TEST HELLO",
      "parameters": {
        "*": "parameters-&",
        "data": {
          "*": "data-&"
        },
        "network": {
          "*": "network-&"
        },
        "deviceClass": {
          "*": "deviceClass-&"
        }
      }
    }
    }
]

Мой ожидаемый результат: 

{
  "id" : 25692584,
  "timestamp" : "2018-11-19T07:23:07.022916",
  "notification" : "$device-add",
  "dev_id" : "TEST HELLO",
  "parameters-id" : "aa190000-3143-0000-2020",
  "parameters-isBlocked" : false,
  "parameters-name" : "aa190000-3143-0000-2020",
  "parameters-status" : "Online",
  "parameters-type" : "DOOR",
  "parameters-time" : "2000-01-01T02:00:39.000000",
  "parameters-secure" : true,
  "parameters-mode" : "idle",
  "parameters-gps.lat" : 24.675699,
  "parameters-gps.long" : 46.663898,
  "parameters-entries" : "959,reboot 0x0001",
  "data-desc" : "Undescribed",
  "data-imei" : "861107036",
  "data-simid" : "89564700000",
  "network-id" : 11,
  "network-name" : "TEST",
  "network-description" : null,
  "deviceClass-id" : 12,
  "deviceClass-name" : "CGM_IOT",
  "deviceClass-version" : "2.0",
  "deviceClass-isPermanent" : false,
  "deviceClass-offlineTimeout" : 60,
  "deviceClass-data" : null,
  "deviceClass-equipment" : [ ]
}

1 Ответ

0 голосов
/ 11 февраля 2019

Во время смены «значения - это ключи» и «ключи - это значения», вы можете использовать #, чтобы установить значение как константу: 

[
  {
    "operation": "shift",
    "spec": {
      "*": "&",
      "#TEST HELLO": "dev_id",
      "parameters": {
        "*": "parameters-&",
        "data": {
          "*": "data-&"
        },
        "network": {
          "*": "network-&"
        },
        "deviceClass": {
          "*": "deviceClass-&"
        }
      }
    }
    }
]
...