mirror of
https://github.com/derf/travelynx
synced 2024-12-15 15:32:30 +00:00
144 lines
2.5 KiB
Perl
144 lines
2.5 KiB
Perl
package Travelynx::Command::influxdb;
|
|
|
|
# Copyright (C) 2022 Birte Kristina Friesel
|
|
#
|
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
use Mojo::Base 'Mojolicious::Command';
|
|
|
|
use DateTime;
|
|
|
|
has description => 'Generate statistics for InfluxDB';
|
|
|
|
has usage => sub { shift->extract_usage };
|
|
|
|
sub query_to_influx {
|
|
my ( $label, $value ) = @_;
|
|
|
|
if ( defined $value ) {
|
|
return sprintf( '%s=%f', $label, $value );
|
|
}
|
|
return;
|
|
}
|
|
|
|
sub run {
|
|
my ($self) = @_;
|
|
|
|
my $db = $self->app->pg->db;
|
|
|
|
my $now = DateTime->now( time_zone => 'Europe/Berlin' );
|
|
my $active = $now->clone->subtract( months => 1 );
|
|
|
|
my @stats;
|
|
my @traewelling;
|
|
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'pending_user_count',
|
|
$db->select( 'users', 'count(*) as count', { status => 0 } )
|
|
->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'reg_user_count',
|
|
$db->select( 'users', 'count(*) as count', { status => 1 } )
|
|
->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'active_user_count',
|
|
$db->select(
|
|
'users',
|
|
'count(*) as count',
|
|
{
|
|
status => 1,
|
|
last_seen => { '>', $active }
|
|
}
|
|
)->hash->{count}
|
|
)
|
|
);
|
|
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'checked_in_count',
|
|
$db->select( 'in_transit', 'count(*) as count' )->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'checkin_count',
|
|
$db->select( 'journeys', 'count(*) as count' )->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'polyline_count',
|
|
$db->select( 'polylines', 'count(*) as count' )->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@traewelling,
|
|
query_to_influx(
|
|
'pull_user_count',
|
|
$db->select(
|
|
'traewelling',
|
|
'count(*) as count',
|
|
{ pull_sync => 1 }
|
|
)->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@traewelling,
|
|
query_to_influx(
|
|
'push_user_count',
|
|
$db->select(
|
|
'traewelling',
|
|
'count(*) as count',
|
|
{ push_sync => 1 }
|
|
)->hash->{count}
|
|
)
|
|
);
|
|
push(
|
|
@stats,
|
|
query_to_influx(
|
|
'polyline_ratio',
|
|
$db->query(
|
|
'select (select count(polyline_id) from journeys)::float / (select count(*) from polylines) as ratio'
|
|
)->hash->{ratio}
|
|
)
|
|
);
|
|
|
|
if ( $self->app->config->{influxdb}->{url} ) {
|
|
$self->app->ua->post_p(
|
|
$self->app->config->{influxdb}->{url},
|
|
'stats ' . join( ',', @stats )
|
|
)->wait;
|
|
$self->app->ua->post_p(
|
|
$self->app->config->{influxdb}->{url},
|
|
'traewelling ' . join( ',', @traewelling )
|
|
)->wait;
|
|
}
|
|
else {
|
|
$self->app->log->warn(
|
|
"influxdb command called, but no influxdb url has been configured");
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
1;
|
|
|
|
__END__
|
|
|
|
=head1 SYNOPSIS
|
|
|
|
Usage: index.pl influxdb
|
|
|
|
Write statistics to InfluxDB
|