import paho.mqtt.client
import ssl
import subprocess
import json

Endpoint = "xxxxxxxxxxxxxxxxxxxxx.iot.ap-northeast-1.amazonaws.com"
Port = 8883
SubTopic = "topic/to/subscribe"
RootCAFile = "AmazonRootCA1.pem"
CertFile = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx-certificate.pem.crt"
KeyFile = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx-private.pem.key"


def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe(SubTopic)


def on_message(client, userdata, msg):
    print("Received:" + msg.payload.decode("utf-8"))


if __name__ == '__main__':
    client = paho.mqtt.client.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.tls_set(
        RootCAFile,
        certfile=CertFile,
        keyfile=KeyFile,
        cert_reqs=ssl.CERT_REQUIRED,
        tls_version=ssl.PROTOCOL_TLSv1_2,
        ciphers=None)
    client.connect(Endpoint, port=Port, keepalive=60)
    client.loop_forever()

# coding: utf-8
import json
import boto3

iot = boto3.client("iot-data","ap-northeast-1")


def lambda_handler(event, context):

    topic = "topic/to/subscribe"
    payload = {
        "message": "AWS Lambda からの挨拶"
    }

    try:
        iot.publish(
            topic=topic,
            qos=0,
            payload=json.dumps(payload, ensure_ascii=False)
        )

        return "Succeeeded."

    except Exception as e:
        print(e)
        return "Failed."

SAMPLE_APPLIANCES = [
    {
        "applianceId": "Bot",
        "manufacturerName": "Sample Manufacturer",
        "modelName": "Smart Switch",
        "version": "1",
        "friendlyName": "温湿度マイスター",
        "friendlyDescription": "最適な室内環境を目指します。",
        "isReachable": True,
        "actions": [
            "turnOn",
            "turnOff"
        ],
        "additionalApplianceDetails": {
            "detail1": "For simplicity, this is the only appliance",
            "detail2": "that has some values in the additionalApplianceDetails"
        }
    },
]

def get_display_categories_from_v2_appliance(appliance):
    model_name = appliance["modelName"]
    if model_name == "Smart Switch": displayCategories = ["THERMOSTAT"]
    return displayCategories

import boto3

...
省略
...

client = boto3.client("iot-data", region_name="ap-northeast-1")

def send_command() :
    payload = {
        "message": "関数を実行するぜ！！"
    }

    topic ="topic/to/subscribe"
    client.publish(
        topic=topic,
        qos=0,
        payload=json.dumps(payload, ensure_ascii=False)
    )

import paho.mqtt.client
import ssl
import subprocess
import json
import plot

Endpoint = "xxxxxxxxxxxxxxxxxxxxxxx.iot.ap-northeast-1.amazonaws.com"
Port = 8883
SubTopic = "topic/to/subscribe"
RootCAFile = "AmazonRootCA1.pem"
CertFile = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx-certificate.pem.crt"
KeyFile = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx-private.pem.key"


def on_connect(client, userdata, flags, respons_code):
    print("connected")
    client.subscribe(SubTopic)


def on_message(client, userdata, msg):
    print("received:" + msg.payload.decode("utf-8"))
    data = json.loads(msg.payload.decode("utf-8"))
    message = plot.worker()
    cmd = ["./alexa_remote_control.sh", "-e", "speak:" + message]
    res = subprocess.call(cmd)


if __name__ == '__main__':
    client = paho.mqtt.client.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.tls_set(
        RootCAFile,
        certfile=CertFile,
        keyfile=KeyFile,
        cert_reqs=ssl.CERT_REQUIRED,
        tls_version=ssl.PROTOCOL_TLSv1_2,
        ciphers=None)
    client.connect(Endpoint, port=Port, keepalive=60)
    client.loop_forever()

from slack_sdk.web import WebClient
from dynamodb_json import json_util as util
from boto3.session import Session
import matplotlib.pyplot as plt
import numpy as np
import boto3
import datetime
import pytz
import schedule
import time
from boto3.dynamodb.conditions import Key

session = Session(profile_name="default", region_name='ap-northeast-1')
dynamodb = session.resource("dynamodb")
dynamodb_table = dynamodb.Table("mydht22")


def query_table(now):
    begin = now - datetime.timedelta(days=7)
    response = dynamodb_table.query(
        KeyConditionExpression=Key("device_id").eq('01') & Key("timestamp").between(
            begin.isoformat(sep = "T",timespec="milliseconds"),
            now.isoformat(sep = "T",timespec="milliseconds")))
    data = response["Items"]
    return data


def unmarshall(dynamodb_json):
    regular_json = util.loads(dynamodb_json)
    return regular_json


def worker():
    now = datetime.datetime.now(pytz.timezone("Asia/Tokyo"))
    executed_time = now.strftime("%Y-%m-%d %H:%M:%S")
    print("Executed:", executed_time)

    data = query_table(now)
    json_data = unmarshall(data)
    Humidity = []
    Temperature = []
    Timestamp = []
    temp = 0
    humid = 0
    for i in range(len(json_data)):
        temp = json_data[i]["temperature"]
        humid = json_data[i]["humidity"]
        times = json_data[i]["timestamp"][5:16]
        Humidity.append(humid)
        Temperature.append(temp)
        Timestamp.append(times)

    fukaisisuu = np.round(0.81 * temp + 0.01 * humid *
                          (0.99 * temp - 14.3) + 46.3, 2)
    fukai = "不快指数は" + str(fukaisisuu) + "です。"
    if len(Temperature) > 15:
        Temperature = Temperature[len(Temperature) - 15:]
        Humidity = Humidity[len(Humidity) - 15:]
        Timestamp = Timestamp[len(Timestamp) - 15:]

    plt.rcParams["font.family"] = "DejaVu Sans"
    plt.rcParams["mathtext.fontset"] = "stix"
    plt.rcParams["font.size"] = 20
    plt.rcParams["xtick.labelsize"] = 10
    plt.rcParams["ytick.labelsize"] = 10
    plt.rcParams["figure.figsize"] = (8, 6)
    print(fukai)

    fig = plt.figure()
    ax1 = fig.add_subplot(111)
    ln1 = ax1.plot(
        Timestamp,
        Temperature,
        marker='o',
        markeredgewidth=1.,
        markeredgecolor='k',
        color="orange",
        label=r"$Temperature$")
    ax2 = ax1.twinx()
    ln2 = ax2.plot(
        Timestamp,
        Humidity,
        marker='o',
        markeredgewidth=1.,
        markeredgecolor='k',
        color="blue",
        label=r'$Humidity$')
    h1, l1 = ax1.get_legend_handles_labels()
    h2, l2 = ax2.get_legend_handles_labels()
    ax1.legend(h1 + h2, l1 + l2, loc='upper right')
    ax1.set_ylim([20, 32])
    ax2.set_ylim([25, 85])
    ax1.axhspan(25, 28, color="olive", alpha=0.3)
    ax2.axhspan(40, 70, color="royalblue", alpha=0.2)
    ax1.set_xlabel(r"$Timestamp$")
    ax1.set_ylabel(r"$Temperature$")
    ax2.set_ylabel(r"$Humidity$")
    ax1.grid(True)
    plt.gcf().autofmt_xdate()
    plt.savefig("室内温湿度.jpg")

    client = WebClient(
        token="xoxb-xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx")
    response = client.chat_postMessage(text=" Temp : " + str(Temperature[-1]) + "℃, Humid : " + str(
        Humidity[-1]) + "%, message : " + fukai, channel="#home")
    response = client.files_upload(
        channels="#home",
        file="./室内温湿度.jpg",
        title="室内温湿度")

    message = "室内温度は" + str(Temperature[-1]) + \
        "度。湿度は" + str(Humidity[-1]) + "%です。" + fukai
    return message


if __name__ == '__main__':
    session = Session(profile_name="default", region_name="ap-northeast-1")
    dynamodb = session.resource("dynamodb")
    dynamodb_table = dynamodb.Table("mydht22")
    schedule.every(2).seconds.do(worker)
    while True:
        schedule.run_pending()
        time.sleep(1)