Разница с предыдущим значением. kslqDB - PullRequest
Новая
       14

Разница с предыдущим значением. kslqDB

0 голосов
/ 17 января 2020

Я пытался создать пример с помощью ksqlDB

На основе двух свойств, в данном случае "sensor_id" и "user_id".

Я рассчитал изменение поля "value" , когда оба атрибута совпадают.

// TOPI C KAFKA 

{"timestamp": 1000000000, "user_id": "AAAAA", "sensor_id": "sensor_1111", "value": 10000}
{"timestamp": 1555550000, "user_id": "AAAAA", "sensor_id": "sensor_1111", "value": 22000}

{"timestamp": 1666660000, "user_id": "AAAAA", "sensor_id": "sensor_2222", "value": 22000}
{"timestamp": 1777770000, "user_id": "AAAAA", "sensor_id": "sensor_2222", "value": 25000}

{"timestamp": 1666660000, "user_id": "BBBBB", "sensor_id": "sensor_2222", "value": 30000}
{"timestamp": 1777770000, "user_id": "BBBBB", "sensor_id": "sensor_2222", "value": 40000}

Когда эти два значения совпадают, я вычислил разницу с предыдущим.

И прошедшее время.

// РЕЗУЛЬТАТ 

{"timestamp": 1555550000, "last_timestamp": 1000000000, "user_id": "AAAAA", "sensor_id": "sensor_1111", "value": 12000}
{"timestamp": 1777770000, "last_timestamp": 1666660000, "user_id": "AAAAA", "sensor_id": "sensor_2222", "value": 3000}
{"timestamp": 1777770000, "last_timestamp": 1666660000, "user_id": "BBBBB", "sensor_id": "sensor_2222", "value": 10000}
...