The FRaunhofer Opensource SensorThings-Client-Dynamic is a Java-based client library for the SensorThingsAPI and other data models. It aims to simplify development of SensorThings enabled client applications.
- CRUD operations
- Queries on entity sets
- Loading of referenced entities
- MultiDatastreams
- Tasking
- STA plus
- Batch requests
- dataArray (for requesting observations)
- MQTT
Add the dependency:
<dependency>
<groupId>de.fraunhofer.iosb.ilt</groupId>
<artifactId>FROST-Client-Dynamic</artifactId>
<version>2.12</version>
</dependency>
Add the dependency:
compile 'de.fraunhofer.iosb.ilt:FROST-Client-Dynamic:2.12'The SensorThingsService class is central to the library. An instance of it represents a SensorThings service and is identified by an URI.
This class needs to be initialised with a data model, but if initialised without a model it will try to figure out the model automatically.
Data models for the SensorThings API exist, but you can also create your own data models.
The source code below demonstrates the CRUD operations for Thing objects. Operations for other entities work similarly.
SensorThingsSensingV11 modelSensing = new SensorThingsSensingV11();
SensorThingsTaskingV11 modelTasking = new SensorThingsTaskingV11();
URL serviceEndpoint = new URL("http://example.org/v1.0/");
SensorThingsService service = new SensorThingsService(serviceEndpoint, modelSensing, modelTasking);Entity thing = new Entity(modelSensing.etThing)
.setProperty(SensorThingsSensingV11.EP_NAME, "Thingything")
.setProperty(SensorThingsSensingV11.EP_DESCRIPTION, "I'm a thing!")
service.create(thing);
// get Thing with numeric id 1234
thing = service.dao(modelSensing.etThing).find(1234l);
// get Thing with String id ab12cd
thing = service.dao(modelSensing.etThing).find("ab12cd");
thing.setDescription("Things change...");
service.update(thing);
service.delete(thing);Entity Sets are represented by instances of EntityList<>. The query parameters specified by the SensorThingsAPI standard can be applied to queries.
EntitySet things = service.query(modelSensing.etThing)
.count()
.orderBy("description")
.select("name","id","description")
.filter("")
.expand()
.skip(5)
.top(10)
.list();
for (Entity thing : things) {
System.out.println("So many things!");
}Entity sets only load so many entities at a time, but the iterator will automatically
load more entities when more entities exist on the server. To get only the currently
loaded entities, use the toList() method to get the List of currently
loaded entites.
List<Entity> observations = service.query(modelSensing.etObservation)
.count()
.top(1000)
.list()
.toList();
for (Entity obs : observations) {
// Only the loaded Observations...
System.out.println("Observation " + obs.getId() + " has result " + obs.getResult());
}Related entity sets can also be queried.
// Get the thing with ID 1
Entity thing = service.dao(modelSensing.etThing).find(1l);
// Get the Datastreams of this Thing
EntitySet dataStreams = thing.query(modelSensing.npThingDatastreams).list();
for (Entity dataStream : dataStreams) {
Entity sensor = dataStream.getProperty(modelSensing.npDatastreamSensor);
System.out.println("dataStream " + dataStream.getId() + " has Sensor " + sensor.getId());
}Loading referenced objects in one operation (and therefore in one request) is supported. The $expand option of the SensorThingsAPI standard is used internally.
EntitySet things = service.query(modelSensing.etThing)
.expand("Locations($select=name,encodingType,location)")
.list();
for (entity Thing : things) {
EntitySet locations = thing.getProperty(modelSensing.npThingLocations);
}Contributions are welcome!
- Fork this repository
- Commit your changes
- Create a pull request
The code and the documentation of this work is available under the MIT license.
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent