Решение на упр.05 задача 2 от Илиян Гаврилов

Обратно към всички решения

Към профила на Илиян Гаврилов

Код

use std::collections::HashMap;

use std::hash::Hash;

struct Event {

timestamp: u64,

sensor: String,

metric: SensorMetric,

value: f64,

}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]

enum SensorMetric {

Load,

Frequency,

Temperature,

}

fn group_and_aggregate<O, E, D, K>(

events: &[E],

group_fn: impl Fn(&E) -> K,

data_fn: impl Fn(&E) -> Option<D>,

aggregate: impl Fn(&[D]) -> O,

) -> HashMap<K, O>

where

K: Eq + Hash,

{

let mut grouped: HashMap<K, Vec<D>> = HashMap::new();

for event in events {

let key = group_fn(event);

if let Some(data) = data_fn(event) {

grouped.entry(key).or_insert_with(Vec::new).push(data);

}

}

let mut result = HashMap::new();

for (key, data_vec) in grouped {

let aggregated = aggregate(&data_vec);

result.insert(key, aggregated);

}

result

}

trait Aggregator {

type Output;

fn name(&self) -> String;

fn aggregate(&self, events: &[Event]) -> Vec<(String, Self::Output)>;

}

// Имплементирайте агрегация, която връща средната стойност на метриките, групирани по тип.

// Резултата трябва да е вектор от три елемента:

// - ("Load", <средната стойност на Load метриките от всички сензори>)

// - ("Frequency", <средната стойност на Frequency метриките от всички сензори>)

// - ("Temperature", <средната стойност на Temperature метриките от всички сензори>)

struct TotalAggregator {}

impl Aggregator for TotalAggregator {

type Output = f64;

fn name(&self) -> String {

"total".to_string()

}

fn aggregate(&self, events: &[Event]) -> Vec<(String, f64)> {

let mut groups: HashMap<SensorMetric, Vec<f64>> = HashMap::new();

for event in events {

groups.entry(event.metric).or_insert_with(Vec::new).push(event.value);

}

let mut result = Vec::new();

for (metric, values) in groups {

let sum: f64 = values.iter().sum();

let avg = sum / values.len() as f64;

result.push((format!("{:?}", metric), avg));

}

result

}

}

// Имплементирайте агрегация, която по даден тип на метрика, връща сумата от метриките

// от този тип, групирани по сензор.

// Пример при `MetricAggreator { metric: SensorMetric::Load }`, може да върне:

// - ("cpu0", <средната стойност от Load метиките за сензор cpu0>)

// - ("cpu1", <средната стойност от Load метиките за сензор cpu1>)

// - ("gpu0", <средната стойност от Load метиките за сензор gpu0>)

struct MetricAggregator {

metric: SensorMetric

}

impl Aggregator for MetricAggregator {

type Output = f64;

fn name(&self) -> String {

format!("{:?}", self.metric)

}

fn aggregate(&self, events: &[Event]) -> Vec<(String, f64)> {

let mut groups: HashMap<String, Vec<f64>> = HashMap::new();

for event in events {

if event.metric == self.metric {

groups.entry(event.sensor.clone()).or_insert_with(Vec::new).push(event.value);

}

}

let mut result = Vec::new();

for (sensor, values) in groups {

let sum: f64 = values.iter().sum();

let avg = sum / values.len() as f64;

result.push((sensor, avg));

}

result

}

}

fn main() {

let all: Vec<Box<dyn Aggregator<Output=f64>>> = vec![

Box::new(TotalAggregator{}),

Box::new(MetricAggregator{metric: SensorMetric::Load}),

Box::new(MetricAggregator{metric: SensorMetric::Temperature}),

];

let events = &[

Event { timestamp: 0, sensor: String::from("cpu0"), metric: SensorMetric::Load, value: 0.98 },

Event { timestamp: 0, sensor: String::from("cpu1"), metric: SensorMetric::Load, value: 0.04 },

Event { timestamp: 0, sensor: String::from("gpu0"), metric: SensorMetric::Load, value: 13.45 },

Event { timestamp: 0, sensor: String::from("cpu0"), metric: SensorMetric::Frequency, value: 3100.00 },

Event { timestamp: 0, sensor: String::from("cpu1"), metric: SensorMetric::Frequency, value: 3100.00 },

Event { timestamp: 0, sensor: String::from("gpu0"), metric: SensorMetric::Frequency, value: 300.00 },

Event { timestamp: 0, sensor: String::from("cpu0"), metric: SensorMetric::Temperature, value: 56.20 },

Event { timestamp: 0, sensor: String::from("cpu1"), metric: SensorMetric::Temperature, value: 33.33 },

Event { timestamp: 0, sensor: String::from("gpu0"), metric: SensorMetric::Temperature, value: 25.00 },

];

for aggr in &all {

for (key, val) in aggr.aggregate(events) {

println!("{} {:?}: {:.02}", aggr.name(), key, val);

}

}

// total "Temperature": 38.18

// total "Load": 4.82

// total "Frequency": 2166.67

// Load "gpu0": 13.45

// Load "cpu1": 0.04

// Load "cpu0": 0.98

// Temperature "cpu1": 33.33

// Temperature "cpu0": 56.20

// Temperature "gpu0": 25.00

}

Лог от изпълнението

Updating crates.io index
     Locking 17 packages to latest compatible versions
   Compiling proc-macro2 v1.0.103
   Compiling unicode-ident v1.0.22
   Compiling quote v1.0.42
   Compiling futures-sink v0.3.31
   Compiling futures-core v0.3.31
   Compiling futures-channel v0.3.31
   Compiling slab v0.4.11
   Compiling futures-io v0.3.31
   Compiling memchr v2.7.6
   Compiling syn v2.0.110
   Compiling pin-utils v0.1.0
   Compiling pin-project-lite v0.2.16
   Compiling futures-task v0.3.31
   Compiling solution v0.1.0 (/tmp/d20251113-1757769-9jo07g/solution)
warning: struct `Event` is never constructed
 --> src/lib.rs:4:8
  |
4 | struct Event {
  |        ^^^^^
  |
  = note: `#[warn(dead_code)]` on by default

warning: enum `SensorMetric` is never used
  --> src/lib.rs:12:6
   |
12 | enum SensorMetric {
   |      ^^^^^^^^^^^^

warning: function `group_and_aggregate` is never used
  --> src/lib.rs:18:4
   |
18 | fn group_and_aggregate<O, E, D, K>(
   |    ^^^^^^^^^^^^^^^^^^^

warning: trait `Aggregator` is never used
  --> src/lib.rs:46:7
   |
46 | trait Aggregator {
   |       ^^^^^^^^^^

warning: struct `TotalAggregator` is never constructed
  --> src/lib.rs:58:8
   |
58 | struct TotalAggregator {}
   |        ^^^^^^^^^^^^^^^

warning: struct `MetricAggregator` is never constructed
  --> src/lib.rs:91:8
   |
91 | struct MetricAggregator {
   |        ^^^^^^^^^^^^^^^^

warning: function `main` is never used
   --> src/lib.rs:122:4
    |
122 | fn main() {
    |    ^^^^

warning: `solution` (lib) generated 7 warnings
   Compiling futures-macro v0.3.31
   Compiling futures-util v0.3.31
   Compiling futures-executor v0.3.31
   Compiling futures v0.3.31
warning: field `timestamp` is never read
 --> tests/../src/lib.rs:5:3
  |
4 | struct Event {
  |        ----- field in this struct
5 |   timestamp: u64,
  |   ^^^^^^^^^
  |
  = note: `#[warn(dead_code)]` on by default

warning: function `group_and_aggregate` is never used
  --> tests/../src/lib.rs:18:4
   |
18 | fn group_and_aggregate<O, E, D, K>(
   |    ^^^^^^^^^^^^^^^^^^^

warning: method `name` is never used
  --> tests/../src/lib.rs:49:6
   |
46 | trait Aggregator {
   |       ---------- method in this trait
...
49 |   fn name(&self) -> String;
   |      ^^^^

warning: function `main` is never used
   --> tests/../src/lib.rs:122:4
    |
122 | fn main() {
    |    ^^^^

warning: `solution` (test "solution_test") generated 4 warnings
    Finished `test` profile [unoptimized + debuginfo] target(s) in 9.00s
     Running tests/solution_test.rs (target/debug/deps/solution_test-f75e629a1d90e17c)

running 3 tests
test solution_test::test_by_metric_2 ... ok
test solution_test::test_by_metric ... ok
test solution_test::test_total ... ok

test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s

История (1 версия и 0 коментара)