JOLT спецификация для процессора nifi - PullRequest
Новая
       8

JOLT спецификация для процессора nifi

0 голосов
/ 30 августа 2018

У меня следующий ввод JSON 

{
  "events": [
    {
      "cluster_id": "0717-035521-puny598",
      "timestamp": 1535540053785,
      "type": "TERMINATING",
      "details": {
        "reason": {
          "code": "INACTIVITY",
          "parameters": {
            "inactivity_duration_min": "15"
          }
        }
      }
    },
    {
      "cluster_id": "0717-035521-puny598",
      "timestamp": 1535537117300,
      "type": "EXPANDED_DISK",
      "details": {
        "previous_disk_size": 29454626816,
        "disk_size": 136828809216,
        "free_space": 17151311872,
        "instance_id": "6cea5c332af94d7f85aff23e5d8cea37"
      }
    }
  ]
}

Я хочу преобразовать его в следующее.

1) добавить один статический ключ: значение в каждый объект массива «events». 2) удалить один элемент «тип» из каждого объекта массива «события». 3) остальные значения должны быть одинаковыми в i / p и o / p. «детали» - это объект без определенной структуры. 

{
  "events": [
    {
      "new_key" : "new_value",
      "cluster_id": "0717-035521-puny598",
      "timestamp": 1535540053785,

      "details": {
        "reason": {
          "code": "INACTIVITY",
          "parameters": {
            "inactivity_duration_min": "15"
          }
        }
      }
    },
    {
      "new_key" : "new_value",
      "cluster_id": "0717-035521-puny598",
      "timestamp": 1535537117300,

      "details": {
        "previous_disk_size": 29454626816,
        "disk_size": 136828809216,
        "free_space": 17151311872,
        "instance_id": "6cea5c332af94d7f85aff23e5d8cea37"
      }
    }
  ]
}

1 Ответ

0 голосов
/ 30 августа 2018

Должна работать следующая спецификация цепи: 

[
  {
    "operation": "default",
    "spec": {
      "events[]": {
        "*": {
          "new-key": "new-value"
        }
      }
    }
  },
  {
    "operation": "remove",
    "spec": {
      "events": {
        "*": {
          "type": ""
        }
      }
    }
  }
]
...