And this is the detail-info if I click the “View Logs” button from an automated run that didn’t result in data written to the bucket (sorry this is a long line):
2022-03-22 22:01:00
Started task from script: "option task = {\n name: \"SolarHourly\",\n every: 1h,\n offset: 1m,\n}\n\ndata = from(bucket: \"telegraf\")\n |> range(start: -task.every)\n |> filter(fn: (r) => r[\"measurement\"] == \"solar\")\n |> filter(fn: (r) => r[\"topic\"] == \"import\")\n\ndata\n |> aggregateWindow(every: 1h, fn: last, createEmpty: false)\n |> difference(\n nonNegative: true,\n columns: [\"_value\"],\n keepFirst: false,\n )\n |> map(\n fn: (r) => ({\n _value: r._value,\n _field: \"usage\",\n _time: r._time,\n _measurement: \"solar_hourly\",\n }),\n )\n |> to(bucket: \"meters_hourly\"\n // org: \"my-org\",\n )"
This is how the task looks like now (I did some small changes compared to the first post):
option task = {
name: "SolarHourly",
every: 1h,
offset: 1m,
}
data = from(bucket: "telegraf")
|> range(start: -task.every)
|> filter(fn: (r) => r["measurement"] == "solar")
|> filter(fn: (r) => r["topic"] == "import")
data
|> aggregateWindow(every: 1h, fn: last, createEmpty: false)
|> difference(
nonNegative: true,
columns: ["_value"],
keepFirst: false,
)
|> map(
fn: (r) => ({
_value: r._value,
_field: "usage",
_time: r._time,
_measurement: "solar_hourly",
}),
)
|> to(
bucket: "meters_hourly",
org: "my-org",
)
And this is the Bucket content (using the simple query from the GUI with a time range of the last 6 hours), only showing data from the manually started tasks, not the scheduled hourly results: