simple_send_message.py

# -------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
# --------------------------------------------------------------------------

importos
importasyncio
fromazure.iot.device.aioimportIoTHubDeviceClient


asyncdefmain():
# Fetch the connection string from an environment variable
conn_str=os.getenv("IOTHUB_DEVICE_CONNECTION_STRING")

# Create instance of the device client using the connection string
device_client=IoTHubDeviceClient.create_from_connection_string(conn_str)

# Connect the device client.
awaitdevice_client.connect()

# Send a single message
print("Sending message...")
awaitdevice_client.send_message("This is a message that is being sent")
print("Message successfully sent!")

# Finally, shut down the client
awaitdevice_client.shutdown()


if__name__=="__main__":
asyncio.run(main())