import random

import time

import sys

# Using the Python Device SDK for IoT Hub:

#   https://github.com/Azure/azure-iot-sdk-python

# The sample connects to a device-specific MQTT endpoint on your IoT Hub.

import iothub_client

# pylint: disable=E0611

from iothub_client import IoTHubClient, IoTHubClientError, IoTHubTransportProvider, IoTHubClientResult

from iothub_client import IoTHubMessage, IoTHubMessageDispositionResult, IoTHubError, DeviceMethodReturnValue

# The device connection string to authenticate the device with your IoT hub.

# Using the Azure CLI:

# az iot hub device-identity show-connection-string --hub-name {YourIoTHubName} --device-id MyNodeDevice --output table

CONNECTION_STRING = "your device conn string"

# Using the MQTT protocol.

PROTOCOL = IoTHubTransportProvider.MQTT

MESSAGE_TIMEOUT = 

# Define the JSON message to send to IoT Hub.

TEMPERATURE = 20.0

HUMIDITY =

MSG_TXT = "{\"temperature\": %.2f,\"humidity\": %.2f}"

def send_confirmation_callback(message, result, user_context):

    print ( "IoT Hub responded to message with status: %s" % (result) )

def iothub_client_init():

    # Create an IoT Hub client

    client = IoTHubClient(CONNECTION_STRING, PROTOCOL)

    return client

def iothub_client_telemetry_sample_run():

    try:

        client = iothub_client_init()

        print ( "IoT Hub device sending periodic messages, press Ctrl-C to exit" )

        while True:

            # Build the message with simulated telemetry values.

            temperature = TEMPERATURE + (random.random() * )

            humidity = HUMIDITY + (random.random() * )

            msg_txt_formatted = MSG_TXT % (temperature, humidity)

            message = IoTHubMessage(msg_txt_formatted)

            # Add a custom application property to the message.

            # An IoT hub can filter on these properties without access to the message body.

            prop_map = message.properties()

            if temperature > :

              prop_map.add("temperatureAlert", "true")

            else:

              prop_map.add("temperatureAlert", "false")

            # Send the message.

            print( "Sending message: %s" % message.get_string() )

            client.send_event_async(message, send_confirmation_callback, None)

            time.sleep()

    except IoTHubError as iothub_error:

        print ( "Unexpected error %s from IoTHub" % iothub_error )

        return

    except KeyboardInterrupt:

        print ( "IoTHubClient sample stopped" )

if __name__ == '__main__':

    print ( "IoT Hub Quickstart #1 - Simulated device" )

    print ( "Press Ctrl-C to exit" )

    iothub_client_telemetry_sample_run()