Подписка на CB работает, но не отображается

Question

У меня есть сущность, представленная в Контекст-брокере с несколькими атрибутами (такими как температура, влажность и т. Д.). У меня есть база данных MySql, которая сохраняет значения от этого объекта на строка. Поэтому, чтобы сохранить эту информацию, я должен сделать подписку от cygnus. Проблема здесь в том, что информация создается, но когда я запускаю команду (curl http://localhost:1026/v2/subscription), я получаю вывод: [], как будто любая подписка была сделана. Если я сделать команду echo 'db.csubs.count()' | mongo orion --quiet даже показывает вывод 0.

Запуск ОС: Centos 6 Мой Orion Контекст Брокер Версия: 0.26.0

Orion работает как служба:

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

Итак, с первого шага. Предположим, у меня нет подписки, сделанной в базе данных. Я выполняю команду:

/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 

для обеспечения работы ломового агента.

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

Питон скрипт является один содержится в папке fiware-figway, представленной в репозитории 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 

Теперь каждый раз, когда я вношу изменения в значения, значение изменяется и создается в базе данных.

Если вам нужна дополнительная информация, не стесняйтесь спрашивать!

EDIT:

Полезная нагрузка "Просить к", "Заголовки:" и "Передача полезной нагрузки":

* 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" 
    } 
} 

Answer 1

Обратите внимание, что вы работаете в режиме Orion мультисервисной. Таким образом, сущности/атрибуты/подписки разделяются тенентами/службами, полностью изолированными в разных базах данных на уровне MongoDB. В частности, обратите внимание, что запрос контекста подписки использует Fiware-Service: fiwarefinal, поэтому подписка создается в службе «fiwarefinal» (связанной с БД orion-fiwarefinal).

Таким образом, curl http://localhost:1026/v2/subscription не будет отображать подписку, так как запрос подсекции разрешен в арендаторе по умолчанию (связанном с базой данных orion). То же самое для echo 'db.csubs.count()' | mongo orion --quiet. Для того, чтобы получить список подписки (или подсчета в БД) для «fiwarefinal» сервиса вы должны использовать:

• curl --header 'Fiware-Service: fiwarefinal' http://localhost:1026/v2/subscription
• echo 'db.csubs.count()' | mongo orion-fiwarefinal --quiet

Обратите внимание, что вы также должны использовать Fiware-Service: fiwarefinal в отказаться от контекстной операции, если вы хотите удалить подписку в «fiwarefinal» арендатор/услуга.

Более подробную информацию о multiservice mode и how it relates with DB level.