6 Historical data on World map 실습

https://sand-court-406.notion.site/6-Historical-data-on-World-map-a92b47dd861f4213a6be4112f128d002

본 FIWARE tutorial의 마지막 내용이다.

World map을 사용해 디바이스가 보낸 정보를 지도에 나타내보는 시각화 과정에 대해 알아보자.

전체적인 내용은 5장 Historical data of Custom FIWARE와 동일하다.

다만 location에 대한 내용과 Grafana를 추가한 버전이라고 생각하면 된다.

로컬 서비스 프로비저닝

curl -iX POST 'http://localhost:4041/iot/services' \
-H 'fiware-service: youngCustomDevice' \
-H 'fiware-servicepath: /escTest' \
-H 'Content-Type: application/json' \
--data-raw '{
    "services": [
        {
            "apikey": "rtestaeyoungtest0818",
            "cbroker": "http://orion:1026",
            "entity_type": "Device",
            "timezone":    "Asia/Seoul",
            "resource": "/iot/d",
            "attributes": [
                {
                    "object_id": "t", "type": "Property", "name": "acoustic",
                    "metadata": { "unitCode": {"type": "Property", "value": "PER" }}
                },
						    {
                    "object_id": "argmax", "name": "max", "type": "Float"
                },
                {
                    "object_id": "c1", "name": "class1", "type": "Float"
                },
								{
                    "object_id": "c2", "name": "class2", "type": "Float"
                },
								{
                    "object_id": "c3", "name": "class3", "type": "Float"
                },
								{
                    "object_id": "c4", "name": "class4", "type": "Float"
                },
								{
                    "object_id": "c5", "name": "class5", "type": "Float"
                },
								{
                    "object_id": "c6", "name": "class6", "type": "Float"
                },
								{
                    "object_id": "c7", "name": "class7", "type": "Float"
                },
								{
                    "object_id": "c8", "name": "class8", "type": "Float"
                },
								{
                    "object_id": "c9", "name": "class9", "type": "Float"
                },
								{
                    "object_id": "c10", "name": "class10", "type": "Float"
                }
            ],
            "static_attributes": [
                {
                    "name": "category", "type": "Property", "value": "sensor"
                },
                {
                    "name": "supportedProtocol", "type": "Property", "value": "ul20"
                }
            ]
        }
    ]
}'
JavaScript
복사

서비스 프로비저닝 결과 확인한다.

curl -X GET \
  'http://localhost:4041/iot/services' \
  -H 'fiware-service: youngCustomDevice' \
  -H 'fiware-servicepath: /escTest' | python3 -m json.tool
JavaScript
복사

{
    "count": 1,
    "services": [
        {
            "commands": [],
            "lazy": [],
            "attributes": [
                {
                    "object_id": "t",
                    "type": "Property",
                    "name": "acoustic",
                    "metadata": {
                        "unitCode": {
                            "type": "Property",
                            "value": "PER"
                        }
                    }
                },
                {
                    "object_id": "argmax",
                    "name": "max",
                    "type": "Float"
                },
                {
                    "object_id": "c1",
                    "name": "class1",
                    "type": "Float"
                },
                {
                    "object_id": "c2",
                    "name": "class2",
                    "type": "Float"
                },
                {
                    "object_id": "c3",
                    "name": "class3",
                    "type": "Float"
                },
                {
                    "object_id": "c4",
                    "name": "class4",
                    "type": "Float"
                },
                {
                    "object_id": "c5",
                    "name": "class5",
                    "type": "Float"
                },
                {
                    "object_id": "c6",
                    "name": "class6",
                    "type": "Float"
                },
                {
                    "object_id": "c7",
                    "name": "class7",
                    "type": "Float"
                },
                {
                    "object_id": "c8",
                    "name": "class8",
                    "type": "Float"
                },
                {
                    "object_id": "c9",
                    "name": "class9",
                    "type": "Float"
                },
                {
                    "object_id": "c10",
                    "name": "class10",
                    "type": "Float"
                }
            ],
            "_id": "636b4d3882a8c05de2936ef4",
            "resource": "/iot/d",
            "apikey": "rtestaeyoungtest0818",
            "service": "youngcustomdevice",
            "subservice": "/escTest",
            "timezone": "Asia/Seoul",
            "__v": 0,
            "static_attributes": [
                {
                    "name": "category",
                    "type": "Property",
                    "value": "sensor"
                },
                {
                    "name": "supportedProtocol",
                    "type": "Property",
                    "value": "ul20"
                }
            ],
            "internal_attributes": [],
            "entity_type": "Device"
        }
    ]
}
JavaScript
복사

Device 프로비져닝

Raspberry Pi에서 디바이스를 등록하자.

curl -L -X POST 'http://172.16.63.209:4041/iot/devices' \
    -H 'fiware-service: youngcustomdevice' \
    -H 'fiware-servicepath: /escTest' \
    -H 'Content-Type: application/json' \
--data-raw '{
  "devices": [
    {
      "device_id": "acoustic01",
      "entity_name": "urn:ngsi-ld:Device:acoustic02",
      "entity_type": "Device",
      "timezone": "Asia/Seoul",
      "attributes": [
        {
          "object_id": "t",
          "name": "acoustic",
          "type": "Property",
          "metadata": {
            "unitCode": {
              "type": "Property",
              "value": "PER"
            }
          }
        }
      ],
      "static_attributes": [
        {"name": "category", "type":"Property", "value": ["sensor"]},
        {"name": "supportedProtocol", "type": "Property", "value": ["ul20"]},
				{"name": "latitude", "type": "Float", "value": 37.585384},
        {"name": "longtitude", "type": "Float", "value": 127.057310}
      ]
    }
  ]
}'
JavaScript
복사

아래 코드를 서버에서 실행해 확인한다.

curl -L -X GET 'http://localhost:1026/ngsi-ld/v1/entities/?type=Device' \
-H 'NGSILD-Tenant: youngcustomdevice' \
-H 'NGSILD-Path: /escTest' \
-H 'Link: <http://context/ngsi-context.jsonld>; rel="http://www.w3.org/ns/json-ld#context"; type="application/ld+json"' | python3 -m json.tool
JavaScript
복사

아래와 같은 결과가 나오면 성공이다.

{
        "id": "urn:ngsi-ld:Device:acoustic02",
        "type": "Device",
        "latitude": {
            "type": "Property",
            "value": 37.585384
        },
        "longtitude": {
            "type": "Property",
            "value": 127.05731
        },
        "category": {
            "type": "Property",
            "value": "sensor"
        },
        "supportedProtocol": {
            "type": "Property",
            "value": "ul20"
        }
    }
JavaScript
복사

Setting up subscriptions

Subscriptions 등록을 처리해주자.

attributes는 간단하게 등록하기 위해 latitude, longtitude, max만 사용하며 다른 값을 넣어도 상관없다.

curl -L -X POST 'http://localhost:1026/ngsi-ld/v1/subscriptions/' \
-H 'Content-Type: application/ld+json' \
-H 'NGSILD-Tenant: youngCustomDevice' \
--data-raw '{
  "description": "Classification result from Pi",
  "type": "Subscription",
  "entities": [{"type": "Device"}],
  "watchedAttributes": ["latitude", "longtitude", "max"],
  "notification": {
    "attributes": ["latitude", "longtitude", "max"],
    "format": "normalized",
    "endpoint": {
      "uri": "http://quantumleap:8668/v2/notify",
      "accept": "application/json"
    }
  },
   "@context": "http://context/ngsi-context.jsonld"
}'
JavaScript
복사

정상 등록을 아래 코드로 확인한다.

curl -X GET \
  'http://localhost:1026/ngsi-ld/v1/subscriptions/' \
  -H 'NGSILD-Tenant: youngCustomDevice' | python3 -m json.tool
JavaScript
복사

아래와 같은 결과가 나오면 문제없이 동작한다.

{
        "id": "urn:ngsi-ld:Subscription:fc0a1648-6023-11ed-8753-0242ac120006",
        "type": "Subscription",
        "description": "Classification result from Pi",
        "entities": [
            {
                "type": "https://uri.fiware.org/ns/data-models#Device"
            }
        ],
        "watchedAttributes": [
            "latitude",
            "longtitude",
            "max"
        ],
        "status": "active",
        "isActive": true,
        "notification": {
            "attributes": [
                "latitude",
                "longtitude",
                "max"
            ],
            "format": "normalized",
            "endpoint": {
                "uri": "http://quantumleap:8668/v2/notify",
                "accept": "application/json"
            },
            "status": "ok",
            "timesSent": 2,
            "lastNotification": "2022-11-09T12:04:28.027Z",
            "lastSuccess": "2022-11-09T12:04:28.028Z"
        }
    }
JavaScript
복사

데이터 추가

실제 데이터를 추가하면서 정상 동작을 검증해보자.

아래 코드를 라즈베리파이에서 실행해 서버로 데이터를 전송하자.

5장에서도 언급했지만 모든 ip주소는 자신이 구축한 서버로 변경해서 진행해야한다.

curl -L -X POST 'http://172.16.63.209:7896/iot/d?k=rtestaeyoungtest0818&i=acoustic02' \
    -H 'Content-Type: text/plain' \
    --data-raw 'argmax|0.8|c1|0.2|c2|0.4|c3|0.6|c4|0.8|c5|1.0|c6|1.2|c7|1.4|c8|1.6|c9|1.8|c10|2.0'
JavaScript
복사

curl -L -X POST 'http://172.16.63.209:7896/iot/d?k=rtestaeyoungtest0818&i=acoustic01' \
    -H 'Content-Type: text/plain' \
    --data-raw 'c1|0.3|c2|0.2|c3|0.5|c4|0.7|c5|0.8|c6|1.4|c7|1.2|c8|1.4|c9|1.4|c10|2.5'
JavaScript
복사

curl -L -X POST 'http://172.16.63.209:7896/iot/d?k=rtestaeyoungtest0818&i=acoustic01' \
    -H 'Content-Type: text/plain' \
    --data-raw 'c1|0.7|c2|0.5|c3|0.4|c4|0.5|c5|0.4|c6|1.6|c7|1.1|c8|1.0|c9|1.3|c10|2.0'
JavaScript
복사

curl -L -X POST 'http://172.16.63.209:7896/iot/d?k=rtestaeyoungtest0818&i=acoustic01' \
    -H 'Content-Type: text/plain' \
    --data-raw 'c1|0.8|c2|0.6|c3|0.3|c4|0.4|c5|0.5|c6|1.5|c7|1.0|c8|1.1|c9|1.1|c10|1.8'
JavaScript
복사

curl -L -X POST 'http://172.16.63.209:7896/iot/d?k=rtestaeyoungtest0818&i=acoustic01' \
    -H 'Content-Type: text/plain' \
    --data-raw 'c1|0.5|c2|0.8|c3|0.1|c4|0.5|c5|0.7|c6|1.0|c7|0.8|c8|1.2|c9|1.5|c10|1.5'
JavaScript
복사