33 строки
1.0 KiB
Python
33 строки
1.0 KiB
Python
# -------------------------------------------------------------------------
|
|
# Copyright (c) Microsoft Corporation. All rights reserved.
|
|
# Licensed under the MIT License. See License.txt in the project root for
|
|
# license information.
|
|
# --------------------------------------------------------------------------
|
|
|
|
import os
|
|
import asyncio
|
|
from azure.iot.device.aio import IoTHubDeviceClient
|
|
|
|
|
|
async def main():
|
|
# 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.
|
|
await device_client.connect()
|
|
|
|
# Send a single message
|
|
print("Sending message...")
|
|
await device_client.send_message("This is a message that is being sent")
|
|
print("Message successfully sent!")
|
|
|
|
# Finally, shut down the client
|
|
await device_client.shutdown()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|