added a licence and updated the README.

Author: argahsuknesib

LICENCE

@@ -0,0 +1,19 @@
+This code is copyrighted by [Ghent University - imec](https://www.ugent.be/ea/idlab/en)
+
+Permission is hereby granted, free of charge, to any person obtaining a
+copy of this software and associated documentation files (the "Software"),
+to deal in the Software without restriction, including without limitation
+the rights to use, copy, modify, merge, publish, distribute, sublicense,
+and/or sell copies of the Software, and to permit persons to whom the
+Software is furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,23 @@
+# Feather RDF Mapper
+
+A simple mapper to map and convert .feather data files into RDF triples in a specified ontology, specifically in the N-Triples format.
+
+## Usage
+
+Note: It is highly advised to use a venv with the required packages installed, as described in the [requirements][./requirements.txt] file.
+
+- Specify the name of the .feather file and the .nt file in the `mapper.py` file inside the mapper folder.
+- Run the file as a script with,
+```bash
+python3 mapper.py
+```
+- The .nt file will be created.
+
+## License
+
+This code is copyrighted by [Ghent University - imec](https://www.ugent.be/ea/idlab/en) and 
+released under the [MIT Licence](./LICENCE)
+
+## Contact
+
+For any questions, please contact [Kush](mailto:kushagrasingh.bisen@ugent.be).

mapper/main.py

@@ -84,7 +84,7 @@ def map_observation(metric_id,
     if metric_group == "CONTEXT":
         return OBSERVATION_TEMPLATE_CONTEXT_DAHCC % (uuid,
                                                      uuid, source_id,
-                                                     uuid, metric_id,
+                                                     uuid, uuid, metric_id,
                                                      uuid, str(timestamp_utc),
                                                      uuid, value
                                                      )
@@ -93,10 +93,18 @@ def map_observation(metric_id,
         #                                        patient_id, metric_id, uuid,
         #                                        metric_id, time_str, str(timestamp_utc), value_str)
     elif metric_group == "WEARABLE":
-        return OBSERVATION_TEMPLATE_WEARABLE % (source_id,
-                                                patient_id, metric_id, uuid,
-                                                patient_id, metric_id, uuid,
-                                                metric_id, time_str, str(timestamp_utc), value_str)
+            return OBSERVATION_TEMPLATE_CONTEXT_DAHCC % (uuid,
+                                                     uuid, source_id,
+                                                     uuid, uuid, metric_id,
+                                                     uuid, str(timestamp_utc),
+                                                     uuid, value
+                                                     )
+
+
+        # return OBSERVATION_TEMPLATE_WEARABLE % (source_id,
+        #                                         patient_id, metric_id, uuid,
+        #                                         patient_id, metric_id, uuid,
+        #                                         metric_id, time_str, str(timestamp_utc), value_str)
 
 
 def map_value(value, metric_id):
@@ -135,9 +143,10 @@ def update_source_id(source_id, metric_id):
 OBSERVATION_TEMPLATE_CONTEXT_DAHCC = """
 <https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <http://rdfs.org/ns/void#inDataset> <https://dahcc.idlab.ugent.be/Protego/_participant1> .
 <https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <https://saref.etsi.org/core/measurementMadeBy> <https://dahcc.idlab.ugent.be/Homelab/SensorsAndActuators/%s> .
+<https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <http://purl.org/dc/terms/isVersionOf> <https://saref.etsi.org/core/Measurement> .
 <https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <https://saref.etsi.org/core/relatesToProperty> <https://dahcc.idlab.ugent.be/Homelab/SensorsAndActuators/%s> .
 <https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <https://saref.etsi.org/core/hasTimestamp> "%s"^^<http://www.w3.org/2001/XMLSchema#dateTime> .
-<https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <https://saref.etsi.org/core/hasValue> "%s"^^<http://www.w3.org/2001/XMLSchema#boolean> .
+<https://dahcc.idlab.ugent.be/Protego/_participant1/obs%s> <https://saref.etsi.org/core/hasValue> "%s"^^<http://www.w3.org/2001/XMLSchema#float> .
 
 """
 
@@ -283,7 +292,7 @@ def convert_timestamp_to_string(timestamp):
 
 
 def generate_uuid(metric_id, patient_id):
-    key = '%s.%s' % (patient_id, metric_id)
+    key = '%s' % (patient_id)
     if key not in uuid_map:
         uuid_map[key] = 0
     result = uuid_map[key]
@@ -297,21 +306,27 @@ def remove_whitespace(given_str):
 
 # MAIN FUNCTION FOR TESTING PURPOSES
 
-file = pandas.read_feather('../data/dataset_participant1.feather')
-metric = 'people.presence.detected'
+file = pandas.read_feather('data/dataset_participant3.feather')
+
+heartRateSensor = ['wearable.bvp'];
+accelerationSensorNames = ['wearable.acceleration.x', 'wearable.acceleration.y', 'wearable.acceleration.z']
+
+numberOfObservations = 500
 
-# print(file.head())
-dataframe = file[file['Metric'] == 'people.presence.detected']
+dataframe_heart_rate = file[file['Metric'] == heartRateSensor[0]].head(numberOfObservations)
+dataframe_acc_x = file[file['Metric'] == accelerationSensorNames[0]].head(numberOfObservations)
+dataframe_acc_y = file[file['Metric'] == accelerationSensorNames[1]].head(numberOfObservations)
+dataframe_acc_z = file[file['Metric'] == accelerationSensorNames[2]].head(numberOfObservations)
+
+dataframe_heart_rate_with_x = dataframe_heart_rate.append(dataframe_acc_x)
+dataframe_heart_rate_with_x_y = dataframe_heart_rate_with_x.append(dataframe_acc_y)
+dataframe = dataframe_heart_rate_with_x_y.append(dataframe_acc_z)
 
 if __name__ == '__main__':
     for index in dataframe.index:
         source = dataframe['Sensor'][index]
         metricId = dataframe['Metric'][index]
         value = dataframe['Value'][index]
-        if value == "1":
-            newValue = "true"
-        else:
-            newValue = "false"
         datetimeValue = dataframe['Timestamp'][index]
         datetimeValueString = str(datetimeValue)
         valueOfHour = datetimeValueString[0:2]
@@ -321,7 +336,7 @@ def remove_whitespace(given_str):
         if (datetimeValueString[9:12] == ''):
             continue
         else:
-            valueOfMiliSeconds = datetimeValueString[9:15]
+            valueOfMiliSeconds = datetimeValueString[9:13]
 
         currentDate = datetime.now()
         year = currentDate.strftime("%Y")
@@ -330,22 +345,19 @@ def remove_whitespace(given_str):
 
         try:
             timeValue = str(year + '-' + month + '-' + day + 'T' + valueOfHour + ':' + valueOfMinute + ':' + valueOfSeconds + '.' + valueOfMiliSeconds)
-            # epoch = datetime(year=year, month=month, day=day, hour=valueOfHour, minute=valueOfMinute,
-            #                  second=valueOfSeconds, microsecond=valueOfMiliSeconds).strftime('%s')
-            # timeValue = epoch
         except Exception as e:
             print(e)
         finally:
             print('Done')
 
         json_event = {
             "sourceId": source,
-            "metricId": "people.presence.detected",
-            "value": newValue,
+            "metricId": metricId,
+            "value": value,
             "timestamp": timeValue
         }
         _result = annotate_event(json_event)
-        with open('/home/kush/Code/feather-RDF-mapper/data/rdfData/dataset_participant1.nt', 'a') as file:
+        with open('/home/kush/Code/feather-RDF-mapper/data/rdfData/dataset_participant3.nt', 'a') as file:
             pass
             file.write('\n')
             file.write(_result)