Internet of Things on Azure

Discover Azure’s main IoT services with practical examples.

Azure IoT Hub

Azure IoT Hub is the central service for managing IoT devices.

Configuring IoT Hub

from azure.iot.hub import IoTHubRegistryManager

# Create the registry manager
registry_manager = IoTHubRegistryManager("<connection_string>")

# Create a device
device = registry_manager.create_device_with_sas(
    device_id="mon-appareil",
    primary_key="<primary_key>",
    secondary_key="<secondary_key>",
    status="enabled"
)

# Create an access policy
policy = registry_manager.create_shared_access_policy(
    hub_name="mon-hub",
    policy_name="mon-policy",
    permissions=["RegistryWrite", "ServiceConnect", "DeviceConnect"]
)

Sending Messages

from azure.iot.device import IoTHubDeviceClient

# Create the client
client = IoTHubDeviceClient.create_from_connection_string("<connection_string>")

# Send a message
message = {
    "temperature": 25.6,
    "humidity": 60,
    "timestamp": "2024-03-22T10:00:00Z"
}
client.send_message(str(message))

Azure IoT Edge

Azure IoT Edge enables local processing on IoT devices.

Configuring an Edge Module

from azure.iot.edge import EdgeModuleClient

# Create the Edge client
client = EdgeModuleClient.create_from_environment()

# Define the callback for messages
async def message_handler(message):
    print(f"Message reçu: {message.data}")

# Start the client
client.on_message_received = message_handler
await client.connect()

Deploying a Module

from azure.iot.hub import IoTHubRegistryManager

# Create the module configuration
module_config = {
    "id": "mon-module",
    "image": "mon-image:latest",
    "createOptions": {
        "HostConfig": {
            "PortBindings": {
                "8080/tcp": [{"HostPort": "8080"}]
            }
        }
    }
}

# Deploy the module
registry_manager.create_module(
    device_id="mon-appareil",
    module_id="mon-module",
    managed_by="iotEdge",
    properties=module_config
)

Azure IoT Central

Azure IoT Central is a complete IoT platform.

Creating an Application

from azure.iot.central import IoTCentralClient

# Create the client
client = IoTCentralClient(
    application_url="<application_url>",
    api_token="<api_token>"
)

# Create a device template
device_template = {
    "name": "Capteur Environnemental",
    "capabilities": {
        "telemetry": [
            {
                "name": "temperature",
                "schema": "double"
            },
            {
                "name": "humidity",
                "schema": "double"
            }
        ]
    }
}

# Create the template
template = client.create_device_template(device_template)

Registering a Device

# Create a device
device = client.create_device(
    device_id="mon-capteur",
    template_id=template.id,
    display_name="Capteur 1"
)

# Get the connection information
connection_info = client.get_device_connection_info(device.id)

Azure Digital Twins

Azure Digital Twins lets you create digital models.

Creating a Digital Twin

from azure.digitaltwins.core import DigitalTwinsClient

# Create the client
client = DigitalTwinsClient(
    endpoint="<endpoint>",
    credential=AzureKeyCredential("<key>")
)

# Create a model
model = {
    "@id": "dtmi:com:example:Building;1",
    "@type": "Interface",
    "contents": [
        {
            "@type": "Property",
            "name": "temperature",
            "schema": "double"
        }
    ]
}

# Create the model
client.create_models([model])

# Create a twin
twin = {
    "$metadata": {
        "$model": "dtmi:com:example:Building;1"
    },
    "temperature": 22.5
}

# Create the twin
client.upsert_digital_twin("building-1", twin)

Azure Time Series Insights

Azure Time Series Insights is used to analyze time series data.

Configuring the Environment

from azure.mgmt.timeseriesinsights import TimeSeriesInsightsClient

# Create the client
client = TimeSeriesInsightsClient(
    credential=AzureKeyCredential("<key>"),
    subscription_id="<subscription_id>"
)

# Create an environment
environment = {
    "location": "westeurope",
    "sku": {
        "name": "S1_1",
        "capacity": 1
    },
    "dataRetentionTime": "P30D"
}

# Create the environment
client.environments.create_or_update(
    resource_group_name="mon-groupe",
    environment_name="mon-env",
    parameters=environment
)

Best Practices

1. Security

   • Use X.509 certificates
   • Implement authentication
   • Secure communications

2. Performance

   • Optimize messages
   • Use batch processing
   • Cache data

3. Monitoring

   • Track metrics
   • Configure alerts
   • Analyze logs

4. Scalability

   • Plan for growth
   • Use partitions
   • Optimize resources

Conclusion

Key takeaways:

• Comprehensive IoT services
• Edge processing available
• Good integration
• Scalability

Recommendations:

• Start with IoT Hub
• Use IoT Edge for local processing
• Set up monitoring
• Follow best practices
• Train on Microsoft Learn