AWS IoT検証メモ③：IoT action

import json
import requests
#from botocore.vendored import requests
#//////////////////////////////////////////////////////////////////////////////
vantiq_uri = "ENTER_VANTIQ_URI"
token = "ENTER_VANTIQ_TOKEN"
VANTIQ_HEADERS = {
    "Authorization" : "Bearer " + token,
    "content-type" : "application/json"
}
#//////////////////////////////////////////////////////////////////////////////

def lambda_handler(event, context):
    print(event)
    #Determining vacant seats
    if event['SensorData'] < 7 :
        Status = True
    else:
        Status = False
    print(Status)
    #Creating a send file for Vantiq
    data={
        "RoomNo": event["DBdata"]["roomNo"],
        "ElementByID":event["DBdata"]["mapElementID"],
        "UseageStatus": Status,
        "Sensorvalue":event['SensorData']
    }
    #Send data
    result=requests.post(vantiq_uri,headers=VANTIQ_HEADERS,data=json.dumps(data))
    print("vantiq_responceResult")
    print(result)

from awscrt import io, mqtt, auth, http
from awsiot import mqtt_connection_builder
import time
import json
import random
#import configdata from AWSConfigFile.py
import AWSConfigFile as config

# Define ENDPOINT, CLIENT_ID, PATH_TO_CERT, PATH_TO_KEY, PATH_TO_ROOT, MESSAGE, TOPIC, and RANGE
ENDPOINT = config.ENDPOINT
CLIENT_ID = config.CLIENT_ID
PATH_TO_CERT = config.PATH_TO_CERT
PATH_TO_KEY = config.PATH_TO_KEY
PATH_TO_ROOT = config.PATH_TO_ROOT
TOPIC = config.TOPIC


# Spin up resources
event_loop_group = io.EventLoopGroup(1)
host_resolver = io.DefaultHostResolver(event_loop_group)
client_bootstrap = io.ClientBootstrap(event_loop_group, host_resolver)
mqtt_connection = mqtt_connection_builder.mtls_from_path(
            endpoint=ENDPOINT,
            cert_filepath=PATH_TO_CERT,
            pri_key_filepath=PATH_TO_KEY,
            client_bootstrap=client_bootstrap,
            ca_filepath=PATH_TO_ROOT,
            client_id=CLIENT_ID,
            clean_session=False,
            keep_alive_secs=6
            )
print("Connecting to {} with client ID '{}'...".format(
        ENDPOINT, CLIENT_ID))
# Make the connect() call
connect_future = mqtt_connection.connect()
# Future.result() waits until a result is available
connect_future.result()
print("AWSAWS IoT Core_MQTTConnected!")
# Publish message to server desired number of times.


try :
    while True:
        time.sleep(30)
        SensorData = random.randint(0,9)

        message ={
            "message":"SendSensorData",
            "SensorData":SensorData,
            "clientID":CLIENT_ID
        }

        mqtt_connection.publish(topic=TOPIC, payload=json.dumps(message), qos=mqtt.QoS.AT_LEAST_ONCE)
        print("Published: '" + json.dumps(message) + "' to the topic: " + TOPIC)

except KeyboardInterrupt:
    print('Exit')

"data": {
  //デバイスからの元データ
  "message": "SendSensorData",
  "SensorData": 3,
  "clientID": "10PC202010012",
  //ルールクエリで追加したtimestamp
  "timestamp": 1617697569446,
  //dynamoDBから抽出した端末の管理データ
  "DBdata": {
    "geoJSON": {
      "coordinates": [
        139.764658,
        35.688752
      ],
      "type": "POINT"
    },
    "address": "東京都港区芝公園４丁目２−８",
    "clientID": "10PC202010012",
    "roomNo": "301",
    "tell": "xxx-xxxx-xxxx",
    "installationDate": "2021/04/02",
    "admin": "Tom",
    "deviceName": "NotePCClient",
    "mapElementID": "MapElement301"
  }
}

{
  "RoomNo": "301",
  "UseageStatus": true,
  "discription": "Room301",
  "ElementByID": "MapElement301",
  "Sensorvalue": "3"
}

/var/runtime/botocore/vendored/requests/api.py:72: DeprecationWarning: You are using the post() function from 'botocore.vendored.requests'.  This dependency was removed from Botocore and will be removed from Lambda after 2021/03/31. https://aws.amazon.com/blogs/developer/removing-the-vendored-version-of-requests-from-botocore/. Install the requests package, 'import requests' directly, and use the requests.post() function instead.