Abfrageoptimierung in Dashdb

Question

id timestamp  status 
167 6/28/2016 8:05:58 PM 0 
167 6/28/2016 8:06:02 PM 0 
167 6/28/2016 8:06:05 PM 0 
167 6/28/2016 8:08:06 PM 0 
167 6/28/2016 8:08:10 PM 0 
167 6/28/2016 8:08:13 PM 3 
167 6/28/2016 8:08:17 PM 3 
167 6/28/2016 8:10:41 PM 3 
167 6/28/2016 8:10:45 PM 3 
167 6/28/2016 8:10:48 PM 3 
167 6/28/2016 8:10:51 PM 0 
167 6/28/2016 8:10:55 PM 0 
167 6/28/2016 8:26:40 PM 0 
167 6/28/2016 8:26:44 PM 0 
167 6/28/2016 8:26:47 PM 3 
167 6/28/2016 8:26:50 PM 3 
167 6/28/2016 8:29:19 PM 3 
167 6/28/2016 8:29:23 PM 3 
167 6/28/2016 8:29:26 PM 0 
167 6/28/2016 8:29:29 PM 0 
167 6/28/2016 8:30:33 PM 0 
167 6/28/2016 8:30:37 PM 0 
167 6/28/2016 8:30:40 PM 3 
167 6/28/2016 8:30:44 PM 3 
167 6/28/2016 8:33:11 PM 3 
167 6/28/2016 8:33:15 PM 3 
167 6/28/2016 8:33:18 PM 0 
167 6/28/2016 8:33:21 PM 0 
167 6/28/2016 8:33:45 PM 0 
167 6/28/2016 8:33:48 PM 0 
167 6/28/2016 8:33:52 PM 0 
167 6/28/2016 8:33:55 PM 3 
167 6/28/2016 8:33:58 PM 3 
167 6/28/2016 8:34:59 PM 3 
167 6/28/2016 8:35:03 PM 3 

Die obigen Daten ist von einem unserer IoT Systeme und es sagt im Grunde, in welchem ​​Zustand sich eine Maschine in WRT ist die timestamp mit 0 being Stop and 3 being running.

Ich möchte Teile in stündlicher Basis hergestellt berechnen in eine Stunde und dafür ist die Logik zu prüfen, ob der Maschinenstatus von 3 auf 0 wechselt, dann hat es einen Aprt erzeugt.

Ich habe dann unter Abfrage geschrieben, und es gibt das beabsichtigte Ergebnis. Die Abfrage funktioniert gut, wenn wir sie zum Beispiel für 3-5 Maschinen ausführen, wenn dieselbe für etwa 100 Maschinen in einem Zeitraum von 24 Stunden ausgeführt wird, würde dies lange dauern. Derzeit dauert die Abfrage 14 Minuten pro Gerät für 1 Stunde Daten.

Infra verwendet - DashDB in bluemix, Daten zu diesem db wird von cloudant wieder ein bluemix Service geschoben.

==== 
select a.runstatus,a.runcount ,b.runstatus,b.runcount from (SELECT a.run_status runstatus, count(a.run_status) runcount 
FROM machinedata a where a.run_status <> (SELECT b.run_status 
     FROM machinedata b 
     WHERE a.machine_id = b.machine_id 
      AND a.timestamp > b.timestamp 
      ORDER BY b.timestamp DESC 
     LIMIT 1 
    ) and a.machine_id = 167 and a.run_status=0 AND a.`timestamp` BETWEEN '2016-06-28 20:00:01' 
            AND '2016-06-28 20:59:59' group by a.run_status) as a, 
     (SELECT a.run_status runstatus, count(a.run_status) runcount 
FROM machinedata a where a.run_status <> (SELECT b.run_status 
     FROM machinedata b 
     WHERE a.machine_id = b.machine_id 
      AND a.timestamp > b.timestamp 
      ORDER BY b.timestamp DESC 
     LIMIT 1 
    ) and a.machine_id = 167 and a.run_status=3 AND a.`timestamp` BETWEEN '2016-06-28 20:00:01' 
            AND '2016-06-28 20:59:59' group by a.run_status) as b 

Answer 1

wird dieser den Job machen:

select timestamp part_produced_time, hour(timestamp) part_produced_hour 
     from (select *, first_value(status) over 
         (order by timestamp asc 
          rows between 1 preceding and current row) 
         as prev_status 
      from machinedata 
      ) 
     where status=0 and prev_status=3