Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-22 08:28:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add database worker job logging

Browse source
This commit is contained in:
Jake Barnby 2025-06-25 14:35:17 -04:00
parent 3fae6ae91c
commit 92a04535ac
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
src/Appwrite/Platform/Workers/Databases.php
View file

@ -4,6 +4,7 @@ namespace Appwrite\Platform\Workers;
use Appwrite\Event\Realtime;
use Exception;
use Swoole\Timer;
use Utopia\CLI\Console;
use Utopia\Database\Database;
use Utopia\Database\Document;
@ -39,6 +40,10 @@ class Databases extends Action
->inject('queueForRealtime')
->inject('log')
->callback($this->action(...));
Timer::tick(10_000, function () {
Console::info('Databases worker heartbeat');
});
}
/**
@ -64,6 +69,14 @@ class Databases extends Action
$document = new Document($payload['document'] ?? []);
$database = new Document($payload['database'] ?? []);
Console::info("Processing database operation: \n" . \json_encode([
'type' => $type,
'projectId' => $project->getId(),
'databaseId' => $database->getId(),
'collectionId' => $collection->getId(),
'documentId' => $document->getId(),
], JSON_PRETTY_PRINT));
$log->addTag('projectId', $project->getId());
$log->addTag('type', $type);
@ -82,6 +95,14 @@ class Databases extends Action
DATABASE_TYPE_DELETE_INDEX => $this->deleteIndex($database, $collection, $document, $project, $dbForPlatform, $dbForProject, $queueForRealtime),
default => throw new Exception('No database operation for type: ' . \strval($type)),
};
Console::info("Finished processing database operation: \n" . \json_encode([
'type' => $type,
'projectId' => $project->getId(),
'databaseId' => $database->getId(),
'collectionId' => $collection->getId(),
'documentId' => $document->getId(),
], JSON_PRETTY_PRINT));
}
/**