InfluxDB for time-series data in Raspberry Pi - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to create a new InfluxDB client connection.

Raspberry Pi

from influxdb_client import InfluxDBClient

client = InfluxDBClient(url=[1], token="my-token", org="my-org")

Drag options to blanks, or click blank then click option'

A"influxdb://localhost"

B"localhost"

C"http://localhost:8086"

D"8086"

Attempts:

3 left

💡 Hint

Common Mistakes

Using only hostname without protocol and port.

Using incorrect URL format.

The URL must include the protocol and port, like "http://localhost:8086" to connect properly.

2fill in blank

medium

Complete the code to write a point with measurement 'temperature' and field 'value' to InfluxDB.

Raspberry Pi

from influxdb_client import Point

point = Point("temperature").field("value", [1])
write_api.write(bucket="my-bucket", record=point)

Drag options to blanks, or click blank then click option'

A25

Btemperature

C"25"

D"value"

Attempts:

3 left

💡 Hint

Common Mistakes

Putting the number inside quotes making it a string.

Using the field name instead of the value.

The field value should be a number, not a string, so use 25 without quotes.

3fill in blank

hard

Fix the error in the query to select temperature values from the last hour.

Raspberry Pi

query = 'from(bucket:"my-bucket") |> range(start: [1])'

Drag options to blanks, or click blank then click option'

A"-1d"

B"-1h"

C"now()"

D"1h"

Attempts:

3 left

💡 Hint

Common Mistakes

Using "now()" which is not a valid start time.

Using "1h" which is a positive duration.

The range start should be "-1h" to get data from the last hour.

4fill in blank

hard

Fill both blanks to create a dictionary comprehension that maps each point's time to its temperature value.

Raspberry Pi

result = {record.[1]: record.[2] for record in tables.records}

Drag options to blanks, or click blank then click option'

Atime

Bget_value()

Cvalue

Dget_time()

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'value' attribute which may not exist.

Using 'get_time()' which is not a method.

Use 'time' attribute for the timestamp and 'get_value()' method to get the temperature value.

5fill in blank

hard

Fill all three blanks to write a point with measurement 'humidity', tag 'location', and field 'value'.

Raspberry Pi

point = Point([1]).tag([2], "office").field([3], 60)

Drag options to blanks, or click blank then click option'

A"humidity"

B"location"

C"value"

D"temperature"

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'temperature' instead of 'humidity' for measurement.

Mixing tag and field keys.

The measurement is 'humidity', the tag key is 'location', and the field key is 'value'.

Practice

1. What is the main purpose of InfluxDB when used with a Raspberry Pi?

easy

A. To run a web server for hosting websites

B. To control GPIO pins directly

C. To compile Python programs

D. To store and manage time-series data like sensor readings

Solution

1. Step 1: Understand InfluxDB's role

   InfluxDB is designed to store time-series data, which means data points collected over time, such as sensor readings.

2. Step 2: Compare with other options

   Running a web server, compiling Python, or controlling GPIO pins are not the main functions of InfluxDB.

3. Final Answer:

   To store and manage time-series data like sensor readings -> Option D

4. Quick Check:

   InfluxDB = time-series data storage [OK]

Hint: InfluxDB is for time-stamped data storage [OK]

Common Mistakes:

• Confusing InfluxDB with web servers
• Thinking InfluxDB compiles code
• Assuming InfluxDB controls hardware pins

2. Which Python code snippet correctly writes a data point to InfluxDB on a Raspberry Pi?

easy

A. client.write_point('temperature', tags={'room':'kitchen'}, fields={'value':22.5})

B. client.write_points([{'measurement':'temperature','tags':{'room':'kitchen'},'fields':{'value':22.5}}])

C. client.write('temperature', {'room':'kitchen'}, 22.5)

D. client.insert_point('temperature', {'room':'kitchen'}, {'value':22.5})

Solution

1. Step 1: Recall correct method name and parameters

   The InfluxDB Python client uses the method write_points to write data points, and it expects a list of dictionaries with keys 'measurement', 'tags', and 'fields'.

2. Step 2: Check each option

   client.write_points([{'measurement':'temperature','tags':{'room':'kitchen'},'fields':{'value':22.5}}]) matches the correct method and data structure. Options B, C, and D use incorrect method names or parameter formats.

3. Final Answer:

   client.write_points([{'measurement':'temperature','tags':{'room':'kitchen'},'fields':{'value':22.5}}]) -> Option B

4. Quick Check:

   Use write_points with list of dicts [OK]

Hint: Use write_points with list of dicts for data [OK]

Common Mistakes:

• Using wrong method names like write_point or insert_point
• Passing dict instead of list of dicts
• Incorrect parameter structure

3. Given this Python code on Raspberry Pi using InfluxDB client:

data = [{"measurement": "humidity", "tags": {"room": "bedroom"}, "fields": {"value": 45}}]
client.write_points(data)
result = client.query('SELECT * FROM humidity WHERE room = \'bedroom\'')
print(list(result.get_points()))

What will be the output?

medium

A. SyntaxError

B. []

C. [{'time': '...', 'room': 'bedroom', 'value': 45}]

D. None

Solution

1. Step 1: Understand data insertion

   The code writes one data point with measurement 'humidity', tag 'room'='bedroom', and field 'value'=45. This data is stored in InfluxDB.

2. Step 2: Query and print results

   The query selects all points from 'humidity' where 'room'='bedroom'. Since the data was just inserted, the query returns that point. Printing the list of points shows a list with one dictionary containing time, room, and value keys.

3. Final Answer:

   [{'time': '...', 'room': 'bedroom', 'value': 45}] -> Option C

4. Quick Check:

   Inserted data queried returns list with one point [OK]

Hint: Inserted points appear in query results as dicts [OK]

Common Mistakes:

• Expecting empty list if data was inserted
• Confusing syntax error with query result
• Assuming None is returned from query

4. This Python code snippet on Raspberry Pi tries to write data to InfluxDB but fails:

data = {'measurement': 'temperature', 'tags': {'room': 'office'}, 'fields': {'value': 21.0}}
client.write_points(data)

What is the error and how to fix it?

medium

A. Error: write_points expects a list of points; fix by wrapping data in a list

B. Error: 'fields' key missing; fix by adding 'fields' key

C. Error: 'measurement' must be a string; fix by converting to string

D. No error; code works fine

Solution

1. Step 1: Identify method parameter requirements

   The write_points method requires a list of data points, even if only one point is written.

2. Step 2: Analyze given code

   The code passes a single dictionary instead of a list containing that dictionary, causing an error.

3. Final Answer:

   Error: write_points expects a list of points; fix by wrapping data in a list -> Option A

4. Quick Check:

   write_points needs list of dicts [OK]

Hint: Always pass a list to write_points even for one point [OK]

Common Mistakes:

• Passing dict instead of list to write_points
• Missing 'fields' key in data point
• Assuming no error occurs

5. You want to store temperature readings from multiple rooms on a Raspberry Pi using InfluxDB. Which Python code correctly writes two points with tags and fields in one call?

hard

A. client.write_points([
{'measurement': 'temperature', 'tags': {'room': 'living'}, 'fields': {'value': 20}},
{'measurement': 'temperature', 'tags': {'room': 'bedroom'}, 'fields': {'value': 22}}
])

B. client.write_points({
'measurement': 'temperature', 'tags': {'room': ['living', 'bedroom']}, 'fields': {'value': [20, 22]}
})

C. client.write_points([
{'measurement': 'temperature', 'tags': {'room': 'living', 'bedroom'}, 'fields': {'value': 20, 22}}
])

D. client.write_points('temperature', tags={'room': ['living', 'bedroom']}, fields={'value': [20, 22]})

Solution

1. Step 1: Understand data structure for multiple points

   Each data point must be a dictionary with 'measurement', 'tags', and 'fields'. Multiple points are passed as a list of such dictionaries.

2. Step 2: Evaluate options

   client.write_points([ {'measurement': 'temperature', 'tags': {'room': 'living'}, 'fields': {'value': 20}}, {'measurement': 'temperature', 'tags': {'room': 'bedroom'}, 'fields': {'value': 22}} ]) correctly uses a list of two dictionaries, each with proper tags and fields. Options A, B, and C misuse data structures or method parameters.

3. Final Answer:

   client.write_points([ {'measurement': 'temperature', 'tags': {'room': 'living'}, 'fields': {'value': 20}}, {'measurement': 'temperature', 'tags': {'room': 'bedroom'}, 'fields': {'value': 22}} ]) -> Option A

4. Quick Check:

   List of dicts for multiple points [OK]

Hint: Send multiple points as list of dicts with tags and fields [OK]

Common Mistakes:

• Passing lists inside tags or fields instead of separate points
• Incorrect method parameters
• Combining tags incorrectly in one dict