Edge-to-cloud data pipeline in IOT Protocols - Mini Project: Build & Apply

Edge-to-cloud data pipeline

📖 Scenario: You work for a company that collects temperature data from sensors at remote locations (the edge). The data must be sent securely and efficiently to a cloud server for storage and analysis.This project will guide you through creating a simple edge-to-cloud data pipeline using MQTT protocol simulation.

🎯 Goal: Build a basic edge-to-cloud data pipeline simulation where sensor data is prepared at the edge, configured with connection details, sent to the cloud, and the cloud prints the received data.

📋 What You'll Learn

Create a dictionary to represent sensor data with exact keys and values

Add a configuration dictionary with MQTT connection details

Write a function to simulate sending data from edge to cloud

Print the cloud's received data output

💡 Why This Matters

🌍 Real World

Edge devices like sensors collect data and send it to cloud servers for storage and analysis using protocols like MQTT.

💼 Career

Understanding how to structure data and configuration for edge-to-cloud communication is essential for IoT engineers and DevOps professionals managing IoT pipelines.

1

Create sensor data dictionary

Create a dictionary called sensor_data with these exact entries: 'sensor_id': 'T1000', 'temperature': 22.5, 'unit': 'Celsius', and 'timestamp': '2024-06-01T12:00:00Z'.

IOT Protocols

# Create the sensor_data dictionary with exact keys and values
# Your code here

Need a hint?

Use curly braces to create a dictionary. Each key-value pair should be separated by a comma.

2

Add MQTT connection configuration

Create a dictionary called mqtt_config with these exact entries: 'broker': 'mqtt.example.com', 'port': 1883, and 'topic': 'sensors/temperature'.

IOT Protocols

sensor_data = {
    'sensor_id': 'T1000',
    'temperature': 22.5,
    'unit': 'Celsius',
    'timestamp': '2024-06-01T12:00:00Z'
}
# Create the mqtt_config dictionary with broker, port, and topic
# Your code here

Need a hint?

Use a dictionary to store connection details for MQTT broker, port, and topic.

3

Simulate sending data from edge to cloud

Define a function called send_to_cloud that takes two parameters: data and config. Inside the function, create a variable message that combines data and config into a single dictionary with keys 'payload' for data and 'connection' for config. Return the message dictionary.

IOT Protocols

sensor_data = {
    'sensor_id': 'T1000',
    'temperature': 22.5,
    'unit': 'Celsius',
    'timestamp': '2024-06-01T12:00:00Z'
}
mqtt_config = {
    'broker': 'mqtt.example.com',
    'port': 1883,
    'topic': 'sensors/temperature'
}
# Define send_to_cloud function to combine data and config
# Your code here

Need a hint?

Define a function with two parameters. Inside, create a dictionary with keys 'payload' and 'connection' holding the parameters. Return this dictionary.

4

Print the cloud's received data

Call the send_to_cloud function with sensor_data and mqtt_config as arguments. Store the result in a variable called cloud_message. Then, print cloud_message.

IOT Protocols

sensor_data = {
    'sensor_id': 'T1000',
    'temperature': 22.5,
    'unit': 'Celsius',
    'timestamp': '2024-06-01T12:00:00Z'
}
mqtt_config = {
    'broker': 'mqtt.example.com',
    'port': 1883,
    'topic': 'sensors/temperature'
}

def send_to_cloud(data, config):
    message = {
        'payload': data,
        'connection': config
    }
    return message

# Call send_to_cloud and print the result
# Your code here

Need a hint?

Call the function with the two dictionaries and print the returned dictionary.