Eu tenho uma entidade representada no Context Broker com vários atributos (como temperatura, umidade etc ...). Eu tenho um banco de dados MySql que persiste os valores dessa entidade porlinha. Então, para persistir nessa informação, eu tenho que fazer uma assinatura do cygnus. O problema aqui é que as informações estão sendo preservadas, mas quando executo o comando(curl http://localhost:1026/v2/subscription) eu recebo a saída:[] como se qualquer assinatura estivesse sendo feita. Se eu fizer o comandoecho 'db.csubs.count()' | mongo orion --quiet mostra até a saída 0.

SO em execução: Centos 6 My Orion Context Broker Versão: 0.26.0

Orion é executado como um serviço:

/usr/bin/contextBroker -port 1026 -logDir /var/log/contextBroker -pidpath /var/run/contextBroker/contextBroker.pid -dbhost localhost -db orion -multiservice

Então, desde o primeiro passo. Vamos supor que eu não tenho nenhuma assinatura feita no banco de dados. Eu executo o comando:

/usr/cygnus/bin/cygnus-flume-ng agent --conf /usr/cygnus/conf/ -f /usr/cygnus/conf/agent_a1.conf -n cygnusagent -Dflume.root.logger=INFO,console

para garantir que um agente flume esteja em execução.

python2.7 SetSubscription.py bus temperature http://188.???.??.???:5050/notify

O script python é o fornecido na pasta fiware-figway fornecida no repositório do github.

import requests, json, re
from collections import Counter
import ConfigParser
import io
import sys

CONFIG_FILE = "../config.ini"

NUM_ARG=len(sys.argv)
COMMAND=sys.argv[0]

if NUM_ARG==4:
   ENTITY_ID=sys.argv[1]
   ENTITY_ATTR=sys.argv[2]
   SERVER_URL=sys.argv[3]
else:
   print 'Usage: '+COMMAND+' [ENTITY ID] [ATTRIBUTE] [SERVER URL]'
   print '  ENTITY ID = Entity you want to watch for changes/updates.'
   print '  ATTRIBUTE = Attribute whose change will trigger notifications. In this example script only this attribute will be notified.'
   print '  SERVER URL = (Local) Server listening for notifications.Example: http://myserver.domain.com:10000'
   print '    It has to be a reachable address:port for the ContextBroker. If you are behind a NAT/Firewall contact your network admin.'
   print
   sys.exit(2)


# Load the configuration file
with open(CONFIG_FILE,'r+') as f:
    sample_config = f.read()
config = ConfigParser.RawConfigParser(allow_no_value=True)
config.readfp(io.BytesIO(sample_config))

CB_HOST=config.get('contextbroker', 'host')
CB_PORT=config.get('contextbroker', 'port')
CB_FIWARE_SERVICE=config.get('contextbroker', 'fiware_service')
CB_AAA=config.get('contextbroker', 'OAuth')
if CB_AAA == "yes":
   TOKEN=config.get('user', 'token')
   TOKEN_SHOW=TOKEN[1:5]+"**********************************************************************"+TOKEN[-5:]
else:
   TOKEN="NULL"
   TOKEN_SHOW="NULL"

NODE_ID=config.get('local', 'host_id')
f.close()

CB_URL = "http://"+CB_HOST+":"+CB_PORT
MIN_INTERVAL = "PT5S"
DURATION = "P1M"
ENTITY_TYPE = ""
ENTITY_ATTR_WATCH = ENTITY_ATTR
ENTITY_ATTR_NOTIFY = ENTITY_ATTR

PAYLOAD = '{ \
    "entities": [ \
        { \
            "type": "'+ENTITY_TYPE+'", \
            "isPattern": "false", \
            "id": "'+ENTITY_ID+'" \
        } \
    ], \
    "attributes": [ \
        "'+ENTITY_ATTR_NOTIFY+'" \
    ], \
    "reference": "'+SERVER_URL+'", \
    "duration": "'+DURATION+'", \
    "notifyConditions": [ \
        { \
            "type": "ONCHANGE", \
            "condValues": [ \
                "'+ENTITY_ATTR_WATCH+'" \
            ] \
        } \
    ], \
    "throttling": "'+MIN_INTERVAL+'" \
}'

HEADERS = {'content-type': 'application/json', 'accept': 'application/json' , 'Fiware-Service': CB_FIWARE_SERVICE ,'X-Auth-Token' : TOKEN}
#HEADERS = {'content-type': 'application/json', 'Fiware-Service': CB_FIWARE_SERVICE ,'X-Auth-Token' : TOKEN}
HEADERS_SHOW = {'content-type': 'application/json', 'accept': 'application/json' , 'Fiware-Service': CB_FIWARE_SERVICE , 'X-Auth-Token' : TOKEN_SHOW}
URL = CB_URL + '/v1/subscribeContext'

print "* Asking to "+URL
print "* Headers: "+str(HEADERS_SHOW)
print "* Sending PAYLOAD: "
print json.dumps(json.loads(PAYLOAD), indent=4)
print
print "..."
r = requests.post(URL, data=PAYLOAD, headers=HEADERS)
print
print "* Status Code: "+str(r.status_code)
print
print r.text

Agora, toda vez que eu faço uma alteração nos valores, o valor é alterado e é mantido no banco de dados.

Se precisar de mais informações, não hesite em perguntar!

EDITAR:

A carga "Solicitando", "Cabeçalhos:" e "Enviando carga":

* Asking to http://188.???.??.???:1026/v1/subscribeContext
* Headers: {'Fiware-Service': 'fiwarefinal', 'content-type': 'application/json', 'accept': 'application/json', 'X-Auth-Token': 'NULL'}
* Sending PAYLOAD:
{
    "reference": "http://localhost:5050/notify",
    "throttling": "PT5S",
    "entities": [
        {
            "type": "",
            "id": "bus1",
            "isPattern": "false"
        }
    ],
    "attributes": [
        "temperature"
    ],
    "duration": "P1M",
    "notifyConditions": [
        {
            "condValues": [
                "temperature"
            ],
            "type": "ONCHANGE"
        }
    ]
}

...

* Status Code: 200

{
  "subscribeResponse" : {
    "subscriptionId" : "56781c2d071f621a6546e740",
    "duration" : "P1M",
    "throttling" : "PT5S"
  }
}