Skip to content

Commit

Permalink
created example of code
Browse files Browse the repository at this point in the history
  • Loading branch information
albertoabellagarcia committed May 14, 2024
1 parent f8748b7 commit 7d69999
Showing 1 changed file with 61 additions and 0 deletions.
61 changes: 61 additions & 0 deletions Distribution/code/code_for_using_dataModel.DCAT-AP_Distribution.py
Original file line number Diff line number Diff line change
@@ -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 = "Distribution"
subject = "dataModel.DCAT-AP"
accessService = {'type': 'Property', 'value': ['']}
attribute = "accessService"
value = accessService
# 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))

accessURL = {'type': 'Property', 'value': ['https://datos.comunidad.madrid/catalogo/dataset/134210b4-3fbc-457d-8064-18d6d8cc785e/resource/fca9a0ef-60b3-44bc-8a69-c17d607b122d/download/alojamientos_turisticos.csv']}
attribute = "accessURL"
value = accessURL
# 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))

availability = "{'type': 'Property', 'value': 'yes'}"
attribute = "availability"
value = availability
# 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))

byteSize = {'type': 'Property', 'value': 43503}
attribute = "byteSize"
value = byteSize
# 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)

0 comments on commit 7d69999

Please sign in to comment.