pub async fn start_influxdb_worker( url: String, database: String, tags: HashMap<String, String>, event_receiver: Receiver<WriteQuery>, )