continuous-analytics-examples
continuous-analytics-examples copied to clipboard
portare i vari casi across sistema
in questo momento l'unico caso che è sviluppato across sistema è quello del fire alarm. Sarebbe bello svilupparli anche quello del DB della pizza (che ora è solo per SSS), l'IoT della pizza (che ora è solo per flux) e magari quello del braccio robotico (che ora è solo in EPL).
ecco i dati del braccio per KSQLDB
CREATE STREAM RoboticArm (id VARCHAR, status VARCHAR, stressLevel INTEGER)
WITH (kafka_topic='RoboticArm', value_format='json', partitions=1);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'ready', 0);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'goodGrasped', 1);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'movingGood', 5);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'ready', 0);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'goodGrasped', 1);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'movingGood', 9);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'placingGood', 3);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'placingGood', 3);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'moving', 2);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'moving', 1);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('1', 'ready', 0);
INSERT INTO RoboticArm (id, status, stressLevel) VALUES ('2', 'ready', 0);