3

いくつかの属性 (温度、湿度など) を持つ Context Broker で表されるエンティティがあります。そのエンティティからの値を行ごとに保持するMySqlデータベースがあります。したがって、その情報を保持するには、cygnus からサブスクリプションを作成する必要があります。ここでの問題は、情報が保持されていることですが、コマンドを実行すると、サブスクリプションが作成されたかのよう(curl http://localhost:1026/v2/subscription)に出力が得られます。[]コマンドecho 'db.csubs.count()' | mongo orion --quietを実行すると、出力0も表示されます。

実行中の OS: Centos 6 My Orion Context Broker バージョン: 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

Flume エージェントが実行されていることを確認します。

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

Python スクリプトは、github リポジトリで提供される fiware-figway フォルダーで提供されるスクリプトです。 

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

値を変更するたびに、値が変更され、データベースに保持されます。

さらに情報が必要な場合は、お気軽にお問い合わせください。

編集：

ペイロード「要求先」、「ヘッダー:」および「送信ペイロード」:

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

1 に答える 1

1

Orion をマルチサービス モードで実行していることに注意してください。したがって、エンティティ/属性/サブスクリプションは、MongoDB レイヤーの異なるデータベースで完全に分離されたテナント/サービスによって分離されます。特に、サブスクライブ コンテキスト リクエストが使用してFiware-Service: fiwarefinalいるため、サブスクリプションは "fiwarefinal" サービス ( orion-fiwarefinalDB に関連付けられている) で作成されることに注意してください。

したがって、サブスクリプション クエリは既定のテナント (データベースcurl http://localhost:1026/v2/subscriptionに関連付けられている) で解決されるため、サブスクリプションは表示されません。orionについても同じですecho 'db.csubs.count()' | mongo orion --quiet。「fiwarefinal」サービスのサブスクリプション リスト (または DB のカウント) を取得するには、次を使用する必要があります。

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

Fiware-Service: fiwarefinal「fiwarefinal」テナント/サービスでサブスクリプションを削除する場合は、サブスクリプション解除コンテキスト操作でも使用する必要があることに注意してください。

マルチサービス モードと 、それが DB レベルとどのように関連するかについての詳細を見つけてください。

于 2015-12-21T15:57:06.430 に答える