主页 / user-12079009

BHADRAKA HERATH's questions

Martin Hope
BHADRAKA HERATH
Asked: 2024-11-05 17:13:02 +0800 CST
  • 6

我有一个 JSON 输入，我使用 JOLT 符号将其转换为另一个 JSON。我有需要保存为键值对的测量值，车站名称和车站编号合并为一个字段，日期字段需要单独保存。除了获取时间并将其转换为 GMT 之外，我已经生成了相应的输出。请查看我的输入 JSON 和预期输出 JSON 并修改我当前的 JOLT。

输入 JSON：

[
  {
    "station_id": 1919,
    "local_time_last_update": "2024-11-05 10:45:21",
    "ts": 1730796321,
    "temperature": 19.7,
    "humidity": 49,
    "pressure": 1026.87,
    "wind_average": 1.6,
    "wind_direction": 270,
    "total_rain": 0,
    "solar_radiation": 0,
    "FDI": 38,
    "fault_status": 0,
    "station_Name": "Silicon Valley "
  }
]

预期产出：

{
  "data": [
    {
      "code": "temperature",
      "value": 19.7
    },
    {
      "code": "humidity",
      "value": 49
    },
    {
      "code": "pressure",
      "value": 1026.87
    },
    {
      "code": "wind_average",
      "value": 1.6
    },
    {
      "code": "wind_direction",
      "value": 270
    },
    {
      "code": "total_rain",
      "value": 0
    },
    {
      "code": "solar_radiation",
      "value": 0
    },
    {
      "code": "FDI",
      "value": 38
    },
    {
      "code": "fault_status",
      "value": 0
    }
  ],
  "stationname": "1919_Silicon Valley",
  "Date": "2024-11-05 08:45:21"
}
  • 所有度量都保存为键值对
  • 车站名称 = 车站名称 + 车站 ID
  • Date” = local_time_last_update 转换为 GMT（ts 字段也可以转换为 GMT）

当前 JOLT 规格：

[
  {
    "operation": "modify-overwrite-beta",
    "spec": {
      "*": {
        "timestamp": "${ts:multiply(1000):format('yyyy-MM-dd HH:mm:ss', 'Etc/GMT-1')}"
      }
    }
  },
  {
    "operation": "remove",
    "spec": {
      "*": {
        "local_time_last_update": "",
        "ts": "",
        "station_id": ""
      }
    }
  },
  {
    "operation": "shift",
    "spec": {
      "*": {
        "timestamp": "Date",
        "*": {
          "$": "data[#2].code",
          "@": "data[#2].value"
        },
        "station_Name": "stationname"
      }
    }
  }
]
json
Martin Hope
BHADRAKA HERATH
Asked: 2024-10-23 14:39:35 +0800 CST
  • 6

我有一个 JOLT，我用它来将温度值转换为摄氏度。我在 NIFI 流程中使用它，得到了具有不同值的不同 JSON 输入。当输入 JSON 中有温度字段时，我的 JOLT 工作正常，但当输入 JSON 中没有温度字段时，我的 JOLT 会生成一个额外的温度列。仅当输入 JSON 中有温度字段时，我才需要我的 JOLT 将温度转换为摄氏度。

输入 JSON

[
  {
    "rx_state": 0,
    "tx_id": 3,
    "temp_1": 54.8,
    "trans_battery_flag": 0,
    "ts": 1729646742,
    "station_name": "abc"
  }
]

JOLT 表达

[
  {
    "operation": "modify-overwrite-beta",
    "spec": {
      "*": {
        "Temp_Cel": "=doubleSum(@(1,temp_1),-32)",
        "temp_1": "=divideAndRound(2,@(1,Temp_Cel),1.8)"
      }
    }
  },
  {
    "operation": "remove",
    "spec": {
      "*": {
        "Temp_Cel": ""
      }
    }
  }
]

仅当 JSON 中存在“temp_1”字段时，我才需要 JOLT 转换温度。例如，以下 JSON 不应在 JOLT 之后给我额外的温度字段

[
  {
    "bar_absolute": 30.206,
    "tz_offset": 3600,
    "bar_sea_level": 30.483,
    "bar_offset": -0.001,
    "bar_trend": 0.016,
    "ts": 1729646742,
    "station_name": "abc"
  }
]
json