maya.public

Parameters

Name	Type	Mode
_iddevice	integer	IN
_start_date	timestamp with time zone	IN
_end_date	timestamp with time zone	IN
idevent	bigint	OUT
iddevice	integer	OUT
idmessage	bigint	OUT
latitude	numeric	OUT
longitude	numeric	OUT
senddate	timestamp with time zone	OUT
receivedate	timestamp with time zone	OUT
speed	real	OUT
direction	real	OUT
odometer	numeric	OUT
ignition_on	boolean	OUT
panicbutton	boolean	OUT
speedaverage	real	OUT
securitystatus	integer	OUT
enabled	boolean	OUT
reason	integer	OUT
otros	USER-DEFINED	OUT
location	USER-DEFINED	OUT
gnx_idmessage	bigint	OUT
creationdate	timestamp with time zone	OUT
eventcat	integer	OUT

Definition

import cassandra
import datetime
from itertools import product
from cassandra.cluster import Cluster
from cassandra.concurrent import execute_concurrent_with_args
# the parse method is time zone aware
from dateutil.parser import parse
import pytz

if _iddevice == None or _start_date == None or _end_date == None:
  return
start_date = parse(_start_date)
# to translate from the client timezone to UTC
start_date_utc = start_date.astimezone(pytz.timezone('UTC'))
tmp_date = start_date_utc
end_date = parse(_end_date)
end_date_utc = end_date.astimezone(pytz.timezone('UTC'))
time_delta = datetime.timedelta(days=1) 
days = [start_date_utc,]
while tmp_date < end_date_utc:
  days += [tmp_date + time_delta ]
  tmp_date += time_delta
senddate0 = start_date_utc.strftime("%Y-%m-%d %H:%M:%S%z")
senddate1 = end_date_utc.strftime("%Y-%m-%d %H:%M:%S%z")
session = Cluster(["10.88.9.242","10.88.9.246","10.88.9.235","10.88.9.231","10.88.9.224","10.88.9.183"], control_connection_timeout=30 ).connect("maya")
# several queries need to be prepared because the partitioning key involves the date_key utc based and accepts only the equality condition
prepared = session.prepare("SELECT idevent,iddevice ,idmessage ,latitude ,longitude ,senddate ,receivedate ,speed ,direction ,odometer ,ignition_on ,panicbutton ,speedaverage ,securitystatus , enabled ,reason ,otros ,location ,gnx_idmessage,creationdate,eventcat FROM event_by_day WHERE iddevice = ? AND date_key = ? AND senddate >= ? AND senddate <= ? ")
args = product([_iddevice,],days,[start_date_utc],[end_date_utc])
result = execute_concurrent_with_args(session,prepared,args)
if result:
    for r in result:
      if r.result_or_exc:
          for l in r.result_or_exc:
            ignition_on = True if (l.ignition_on.lower()[0] == 't') else False
            panicbutton = True if (l.panicbutton.lower()[0] == 't') else False
            enabled = True if (l.enabled.lower()[0] == 't') else False
            yield(int(l.idevent),int(l.iddevice),int(l.idmessage),float(l.latitude) ,float(l.longitude) ,pytz.timezone('UTC').localize(l.senddate) ,pytz.timezone('UTC').localize(l.receivedate) ,float(l.speed) ,float(l.direction) ,float(l.odometer) ,ignition_on ,panicbutton ,float(l.speedaverage),int(l.securitystatus), enabled , int(l.reason) ,l.otros ,l.location ,int(l.gnx_idmessage),pytz.timezone('UTC').localize(l.creationdate),int(l.eventcat))
session.shutdown()

ot_ro_event_cassandra(integer, timestamp with time zone, timestamp with time zone)

Parameters

Definition