Problèmes d'utilisation de Doctrine ODM dans les processus démon

Je veux parler de mon expérience en utilisant Doctrine ODM dans un projet PHP relativement petit dans lequel la base de code principale est concentrée dans les processus démon. Et en général, comment nous avons attaché Doctrine ODM à Yii2. Je vous préviens tout de suite - l'histoire sera très fastidieuse et très probablement intéressante uniquement pour ceux qui ont déjà rencontré des problèmes lors de l'utilisation de Doctrine ODM dans les processus démon.

Où nous allons visser

Il y a environ 6 ans, ils m'ont confié la tâche: couper d'un monolithe en un Yii1morceau de code dans un service séparé. À peine dit que c'était fait. Le framework n'a pas choisi depuis longtemps, sauf que Yiije ne savais rien, puis ils ont annoncé une sortie imminente Yii2, qui à l'époque semblait très élégante / à la mode / jeune, mais la connaissance de la première version de ce framework nous a permis de réduire le seuil d'entrée dans la deuxième version. MongoDB était également à la mode, avec lequel nous étions déjà familiers et travaillions Yii1avec une extension distincte, mais Yii2il était pris en charge dès le départ.

Initialement, le microservice était assez simple: il était nécessaire de recevoir des fichiers des utilisateurs et de les stocker dans un stockage persistant, de conserver des enregistrements de ces fichiers dans la base de données, d'émettre des informations concernant ces fichiers et des liens vers eux en réponse aux demandes pertinentes via l'API.

Au fil du temps, ce micro-service a commencé à se développer: le traitement vidéo, la détection de virus, le stockage distribué dans différentes régions (à la CDN) sont apparus. Le temps a passé rapidement, le projet s'est activement développé et a même subi une refactorisation, mais à un moment donné, en raison des nouvelles tendances et de la croissance professionnelle, un sentiment d'inconfort est apparu lors de l'interaction avec ce projet. Le désir de travailler sur ce projet est devenu de moins en moins et j'ai sérieusement pensé.

Embedded Document . , PHP . , , , . , , . , .

PHP 7- , . ActiveRecord Yii2 — "" , , phpdoc. MongoDB, - , - {user_id : '12'}

, . - , Yii2 . , , , , , .

, , MongoDB.
Symfony Doctrine ORM, Doctrine ODM — ORM MongoDB.

Yii2 Symfony , , :
- — , , .
- — ActiveRecord " " Yii2

, ActiveRecord Doctrine ODM, . , ORM .

. Doctrine DocumentManager ( EntityManager Doctrine ORM). " ".

Dependency Injection Container Yii2 , .

Yii2 DataProvider'a. -, CRUD- . " " . , Yii2. , , — , .

, Doctrine UnitOfWork , .

, : DI- , . - , Symfony .

, :

while (!$this->isShuttingDown()) {
    //  Task,  ,     
    //  MANAGED    ,
    //     
    $task = $this->taskProvider->getNextTask();
    try {
        //   -  , ,  
        $this->someService->runTask($task);
    } catch (SomeException $e) {
        //    :       
        //     MANAGED,      
        //       -     
        $this->switchTaskToError($task, $e);
    }
}

, - dirty ( flush() ), , , .

— clear() "" . , , . clear() , , , $this->someService->runTask($task);

, ( , — ), . . , , . , , . .

:

while (!$this->isShuttingDown()) {
    //  ,  , 
    //   -  ,   
    //    detached,      , 
    //      
    $task = $this->taskProvider->getNextTask();
    try {
        //   -     
        $this->someService->runTask($task);
    } catch (SomeException $e) {
        //    ,  -   
        $this->switchTaskToError($task, $e);
    }
}

taskProvider someService , .

merge. runTask() :

public function runTask(Task $task) {
    $dm = $thic->dmFactory->createDocumentManager();
    $task = $dm->merge($task);
    ....
    $task->setStatus(Task::STATUS_OK);
    $dm->flush();
}

switchTaskToError() :

public function switchTaskToError(Task $task, Throwable $) {
    $dm = $this->dmFactory->createDocumentManager();
    $task = $dm->merge($task);
    $task->setStatus(Task::STATUS_ERROR);
    $task->setError($e->getMessage());
    $dm->flush();
}

, $dm .

, , - . , :

$tasks = $this->taskProvider->getProblemTasks();
$dm = $thic->dmFactory->createDocumentManager();
foreach ($tasks as $task) {
     $task = $dm->merge($task);
     $task->setState(..);
}
$dm->flush();

getProblemTasks , , "" , Task merge(). , merge() — .. , .

, , :

$dm = $thic->dmFactory->createDocumentManager();
$tasks = $this->taskProvider->getProblemTasks($dm);
foreach ($tasks as $task) {
     $task->setState(..);
}
$dm->flush();

.

JPA

, Doctrine JPA: , UnitOfWork, (managed, detached ..). JPA , , . , — . (Spring Framework ). JPA , , .

, , . - , , - (? ), ( ). , , .

, hibernate Doctrine.

Doctrine ODM

" doctrine" , - http , , , .

, . , . . , :

$session = $this->sessionManager->createNewSession();
try {
    $dm= $session->getDocumentManager();
    $tasks = $this->taskProvider->getProblemTasks();
    foreach ($tasks as $task) {
        $task->setState(..);
    }
    $dm->flush();
} finally {
    $this->sessionManager->close($session);
}

getProblemTasks

public function getProblemTasks(): array
{
    $repo = $this->sessionManager
                      ->getCurrentSession()
                      ->getDocumentManager()
                      ->getRepository(Task::class);

    return $repo->findBy(['status' => Task::STATUS_ERROR]);
}

, , , , .

:

public function switchTaskToError(Task $task, Throwable $) {
    //   ,  ,    
    $session $this->sessionManager->createNewSession();
    $dm = $session->getDocumentManager();
    try {
        $task = $dm->merge($task);
        $task->setStatus(Task::STATUS_ERROR);
        $task->setError($e->getMessage());
        $dm->flush();
    finally {
        $this->sessionManager->close($session);
    }
}

, , , wrap, , .

, 3 SessionManager

createNewSession — , "" .
getCurrentSession — .
close —

, ( php-ds).

:
createNewSession — , .
getCurrentSession — , , .
close — .

, , , .

wrap, , :

public function switchTaskToError(Task $task, Throwable $) {
    $this->sessionManager->wrapBySession(function(DocumentManager $dm) use ($task, $e) {
        $task = $dm->merge($task);
        $task->setStatus(Task::STATUS_ERROR);
        $task->setError($e->getMessage());
        $dm->flush();
    });
}

En général, le mécanisme de session s'est avéré assez pratique. Au moins, il a résolu tous nos problèmes. Bien sûr, il serait bien de gérer également les sessions en utilisant une approche déclarative, comme c'est le cas dans Spring Framework, par exemple. Cela réduirait considérablement les frais généraux sous forme de code redondant, mais pour le moment je ne peux même pas imaginer comment cela peut être fait en PHP.