[
Date Prev][
Date Next][
Thread Prev][
Thread Next][
Date Index][
Thread Index]
[
List Home]
|
[mihini-dev] Mihini PushData Policy
|
Hi Guys
I have configured the data.policy as per below.
agent.config.data.policy.everyminute={period=60} --consolidation policy every minute
agent.config.data.policy.every10minutes={period=10*60} --sending data policy every 10 minutes
And i am creating asset as per the following code and i am
trying to push the data on every minute interval but i am getting
the data in m3da server only one time at start of code running.
assert(airvantage.init())
local asset = airvantage.newasset("house")
assert(asset:start())
asset:pushdata ('door', "open", 'everyminute')
My guess is i should get the data on every minute please guide me
how to push data on every minute bases and what is the meaning of
Nov 20 19:18:01 Mihini: 2014-11-20 19:18:01 DATAMGR-INFO: flushing policy "everyminute".
Here is my syslog output:
Nov 20 19:16:58 Mihini: 2014-11-20 19:16:58 EMP-DEBUG: [->RCV] [CMD] #1 Register "house"
Nov 20 19:16:58 Mihini: 2014-11-20 19:16:58 EMP-DEBUG: payload = house, type = string, serialized = "house"
Nov 20 19:16:58 Mihini: 2014-11-20 19:16:58 ASSCON-DETAIL: Registering [table: 0x8cfc8d0] as asset (house)...
Nov 20 19:16:58 Mihini: 2014-11-20 19:16:58 ASSCON-INFO: Asset registered, name="house", id=table: 0x8cfc8d0.
Nov 20 19:16:58 Mihini: 2014-11-20 19:16:58 EMP-DEBUG: [<-SND] [RSP] #0 Register null
Nov 20 19:16:59 Mihini: 2014-11-20 19:16:59 EMP-DEBUG: [->RCV] [CMD] #1 PData {"data":"open","policy":"everyminute","asset":"house","path":"door"}
Nov 20 19:16:59 Mihini: 2014-11-20 19:16:59 EMP-DEBUG: payload = table: 0x8cf6620, type = table, serialized = {"data":"open","policy":"everyminute","asset":"house","path":"door"}
Nov 20 19:16:59 Mihini: 2014-11-20 19:16:59 EMP-DEBUG: [<-SND] [RSP] #0 PData null
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 DATAMGR-DETAIL: Policy "everyminute" setup to triggered after latency
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-SESSION-INFO: Opening default session #6
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 DATAMGR-DETAIL: sending table house:door (1 rows of 1 columns) to server
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-TRANSPORT-DEBUG: Opening socket
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 BYSANT-M3DA-DEBUG: Streaming 8 bytes of payload
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 BYSANT-M3DA-DEBUG: Streaming header
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 BYSANT-M3DA-DEBUG: Streaming 13 bytes of payload
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 BYSANT-M3DA-DEBUG: Streaming footer nil
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-SESSION-DEBUG: Waiting for server response...
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-TRANSPORT-DEBUG: Received 13 bytes from server
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-SESSION-INFO: Closing default session #6 with status 200.
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 M3DA-SESSION-DEBUG: Received a 0 bytes message
Nov 20 19:17:01 Mihini: 2014-11-20 19:17:01 SCHED-PIPE-DEBUG: Pipe table: 0x8cbae38 empty, :receive() waits for data
Nov 20 19:17:31 Mihini: 2014-11-20 19:17:31 M3DA-TRANSPORT-DEBUG: Closing socket: closed
Nov 20 19:18:01 Mihini: 2014-11-20 19:18:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:19:01 Mihini: 2014-11-20 19:19:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:20:01 Mihini: 2014-11-20 19:20:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:21:01 Mihini: 2014-11-20 19:21:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:22:01 Mihini: 2014-11-20 19:22:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:23:01 Mihini: 2014-11-20 19:23:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:24:01 Mihini: 2014-11-20 19:24:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:25:01 Mihini: 2014-11-20 19:25:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:25:30 Mihini: 2014-11-20 19:25:30 DATAMGR-INFO: flushing policy "every10minutes"
Nov 20 19:26:01 Mihini: 2014-11-20 19:26:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:27:01 Mihini: 2014-11-20 19:27:01 DATAMGR-INFO: flushing policy "everyminute"
Nov 20 19:28:01 Mihini: 2014-11-20 19:28:01 DATAMGR-INFO: flushing policy "everyminute"
My m3da server output:
{"house.door":[{"value":["open"],"timestamp":"1416491221101"}]}
