Ukázkové kódy
Po naimportování nuget knihovny do projektu se do databáze připojíme pomocí následujícího kódu:
var influxDBClient = InfluxDBClientFactory.Create(url, token);
- Url a token získáme pomocí kroků v připojení.
Ukázka dotazu pro získání dat ohledně běžících sezení:
private static async Task<List<FluxTable>> GetFluxTables(int companyId, string measurement)
{
var flux = "from(bucket:\"mluvii_realtime\") " +
"|> range(start: -1h)" +
$"|> filter(fn: (r) => r[\"_measurement\"] == \"{measurement}\")" +
"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
return await influxDBClient.GetQueryApi().QueryAsync(flux, org: $"company_{companyId}");
}
- Bucket je vždycky stejný, tedy "mluvii_realtime"
- CompanyId je id společnosti
- Measurement je kombinace jména metriky a suffixu v nastavení metrik v mluvii.
Příklad: running_sessions_demo, kde "running_sessions" je název metriky a "demo" je nastaveno v mluvii
Last modified 1mo ago