ExternalVendorCode/OpenMTC
1
0
Fork 0
mirror of https://github.com/OpenMTC/OpenMTC.git synced 2025-02-20 17:12:47 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

small fixes for orion app when run without OCB

Browse Source
This commit is contained in:
Ronald Steinke 2018-10-05 10:40:33 +02:00
parent 4e29b4a04d
commit 7f2889ed5f
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/OrionContextBroker/src/orioncontextbroker/orion_api.py
View File

@ -43,6 +43,13 @@ class OrionAPI(LoggerMixin):
self.logger.error('Type of "{}" unknown'.format(element))
return u"Unknown"
def is_host_alive(self):
req = self._request(
"{}/v2/entities".format(self.host),
method="get"
)
return req['status'] >= 0
def create_entity(self,
entity_name,
entity_type="openmtc",

10
apps/OrionContextBroker/src/orioncontextbroker/orion_context_broker.py
View File

@ -37,10 +37,13 @@ class OrionContextBroker(ResourceManagementXAE):
accumulate_address = "http://" + self._get_auto_host(orion_host) + ":8080"
# Orion API
self._dry_run = not orion_host
self.orion_api = OrionAPI(
orion_host=orion_host,
api_version=orion_api,
accumulate_endpoint="{}/accumulate".format(accumulate_address))
if not self._dry_run:
self._dry_run = not self.orion_api.is_host_alive()
# Subscription Sink for OCB
self.app = Flask(__name__)
@ -116,6 +119,9 @@ class OrionContextBroker(ResourceManagementXAE):
return re.sub('[\W]', '_', f_s), '%s-%s' % (e_pre, dev_id)
def _sensor_data_cb(self, sensor_info, sensor_data):
if self._dry_run:
return
try:
fiware_service, entity_name = self._entity_names[sensor_info['ID']]
except KeyError:
@ -138,6 +144,10 @@ class OrionContextBroker(ResourceManagementXAE):
'ID']]
self.logger.info("Create new Entity {} on Fiware Service {}".format(
entity_name, fiware_service))
if self._dry_run:
return
self.orion_api.create_entity(
entity_name, fiware_service=fiware_service)
data_dummy = {