Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

periodic metric

Browse Source
This commit is contained in:
Damodar Lohani
2025-01-27 06:11:58 +00:00
parent 066273d0db
commit 5d5547c6b9
1 changed files with 26 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Workers/Usage.php
+26 -16
View File
@@ -17,6 +17,14 @@ use Utopia\System\System;
class Usage extends Action
{
/**
* Date format for different periods
*/
protected array $periods = [
'1h' => 'Y-m-d H:00',
'1d' => 'Y-m-d 00:00',
'inf' => '0000-00-00 00:00'
];
/**
* Log Error Callback
*
@@ -493,22 +501,24 @@ class Usage extends Action
}
protected function createOrUpdateMetric(Database $dbForLogs, string $region, string $metric, int $value)
{
$id = md5(self::INFINITY_PERIOD . $metric);
$current = $dbForLogs->getDocument('stats', $id);
if ($current->isEmpty()) {
$dbForLogs->createDocument('stats', new Document([
'$id' => $id,
'metric' => $metric,
'period' => 'inf',
'region' => $region,
'value' => $value,
]));
Console::success('Usage logs created for metric: ' . $metric);
} else {
$dbForLogs->updateDocument('stats', $id, $current->setAttribute('value', $value));
Console::success('Usage logs updated for metric: ' . $metric);
{
foreach ($this->periods as $period => $format) {
$time = 'inf' === $period ? null : \date($format, \time());
$id = \md5("{$time}_{$period}_{$metric}");
$current = $dbForLogs->getDocument('stats', $id);
if ($current->isEmpty()) {
$dbForLogs->createDocument('stats', new Document([
'$id' => $id,
'metric' => $metric,
'period' => $period,
'region' => $region,
'value' => $value,
]));
Console::success('Usage logs created for metric: ' . $metric . ' period:'. $period);
} else {
$dbForLogs->updateDocument('stats', $id, $current->setAttribute('value', $value));
Console::success('Usage logs updated for metric: ' . $metric . ' period:'. $period);
}
}
}
}