diff --git a/Meter/code/code_for_using_dataModel.SAREF_Meter.py b/Meter/code/code_for_using_dataModel.SAREF_Meter.py new file mode 100644 index 0000000..18b4c89 --- /dev/null +++ b/Meter/code/code_for_using_dataModel.SAREF_Meter.py @@ -0,0 +1,61 @@ + +# # This code allows you to install a orion-ld broker in a linux system +# # The manuals are here https://github.com/FIWARE/context.Orion-LD/tree/develop/doc/manuals-ld +# +# # INSTALL NGSI LD broker (OrionLD) +# sudo docker pull mongo:3.6 +# sudo docker pull fiware/orion-ld +# sudo docker network create fiware_default +# sudo docker run -d --name=mongo-db --network=fiware_default --expose=27017 mongo:3.6 --bind_ip_all --smallfiles +# sudo docker run -d --name fiware-orionld -h orion --network=fiware_default -p 1026:1026 fiware/orion-ld -dbhost mongo-db +# +# # TO RELAUNCH (only if you have already installed a broker in the same machine) +# sudo docker stop fiware-orionld +# sudo docker rm fiware-orionld +# sudo docker stop mongo-db +# sudo docker rm mongo-db +# sudo docker network rm fiware_default +# +# # CHECK INSTANCES +# # Check the broker is running +# curl -X GET 'http://localhost:1026/version' +# +# # Check what entities are in the broker +# curl -X GET http://localhost:1026/ngsi-ld/v1/entities?local=true&limit=1000 +# +# # now the python code you can use to insert some value in the context broker according to the data model +# +from pysmartdatamodels import pysmartdatamodels as sdm +import subprocess +serverUrl = "http://localhost:1026" # supposed that your broker is installed in localhost. Edit to match your configuration +dataModel = "Meter" +subject = "dataModel.SAREF" +hasMeterReading = {'type': 'Property', 'unitCode': 'NA', 'observedAt': '2023-01-26T14:05:57Z', 'value': 0.2858275914845758} +attribute = "hasMeterReading" +value = hasMeterReading +# The next line creates the query for inserting this attribute in a NGSI-LD context broker if the attribute does not exist it creates it +print(sdm.update_broker(dataModel, subject, attribute, value, serverUrl=serverUrl, updateThenCreate=True)) + +hasMeterReadingType = "{'type': 'Property', 'value': 'Smoke'}" +attribute = "hasMeterReadingType" +value = hasMeterReadingType +# The next line creates the query for inserting this attribute in a NGSI-LD context broker if the attribute does not exist it creates it +print(sdm.update_broker(dataModel, subject, attribute, value, serverUrl=serverUrl, updateThenCreate=True)) + +hasManufacturer = "{'type': 'Property', 'value': 'Meter Company Inc.'}" +attribute = "hasManufacturer" +value = hasManufacturer +# The next line creates the query for inserting this attribute in a NGSI-LD context broker if the attribute does not exist it creates it +print(sdm.update_broker(dataModel, subject, attribute, value, serverUrl=serverUrl, updateThenCreate=True)) + +hasModel = "{'type': 'Property', 'value': 'Meter 0.1.2'}" +attribute = "hasModel" +value = hasModel +# The next line creates the query for inserting this attribute in a NGSI-LD context broker if the attribute does not exist it creates it +print(sdm.update_broker(dataModel, subject, attribute, value, serverUrl=serverUrl, updateThenCreate=True)) + +print(" In case you have installed the orion-ld broker (see comments on the header of this program)") +print(" Execute this instruction to check that the entities has been inserted") +command = ['curl', '-X', 'GET', 'http://localhost:1026/ngsi-ld/v1/entities?local=true&limit=1000'] +result = subprocess.run(command, capture_output=True, text=True) +print(result.stdout)