{"id":2027,"date":"2025-11-28T15:58:06","date_gmt":"2025-11-28T14:58:06","guid":{"rendered":"https:\/\/www.loicmathieu.fr\/wordpress\/fr\/?p=2027"},"modified":"2025-12-12T10:26:54","modified_gmt":"2025-12-12T09:26:54","slug":"implementing-a-lock-in-elasticsearch","status":"publish","type":"post","link":"https:\/\/www.loicmathieu.fr\/wordpress\/fr\/informatique\/implementer-un-lock-en-elasticsearch\/","title":{"rendered":"Impl\u00e9menter un lock en Elasticsearch"},"content":{"rendered":"

A Kestra<\/a>, la plateforme d’orchestration et de scheduling de workflow pour laquelle je travaille, nous avons deux impl\u00e9mentations de repository: JDBC (avec support pour H2, MySQL et Postgres) et Elasticsearch.<\/p>\n

En JDBC, locker un enregistrement pour le traiter est assez facile :<\/p>\n

    \n
  1. SELECT FOR UPDATE ... WHERE ...<\/code> va poser un lock sur le ou les enregistrements<\/li>\n
  2. On traite le ou les enregistrements dans la m\u00eame transaction<\/li>\n
  3. UPDATE...<\/code><\/li>\n<\/ol>\n

    En fin de transaction, la BDD va automatiquement rel\u00e2cher les locks obtenu via le SELECT FOR UPDATE<\/code>.<\/p>\n

    Mais Elasticsearch ne supporte ni les locks ni les transactions, existe-t-il un moyen de simuler un lock?<\/p>\n

    Index vs Doc API<\/h2>\n

    Elasticsearch est en m\u00eame temps une base de donn\u00e9es NoSQL et un moteur de recherche.\nComme tout moteur de recherche, il se base sur une phase d’indexation asynchrone.<\/p>\n

    Cela a deux cons\u00e9quences :<\/p>\n

      \n
    1. Une recherche peut ne pas retourner un document existant<\/li>\n
    2. Une indexation va par d\u00e9faut \u00e9craser tout document existant<\/li>\n<\/ol>\n

      Pour palier \u00e0 \u00e7a, il y a deux solutions :<\/p>\n

        \n
      1. Utiliser la Doc API pour charger un document depuis son identifiant au lieu de faire une recherche. Pour que cela marche, il faut fixer l’identifiant du document lors de son indexation et ne pas laisser Elasticsearch d\u00e9finir un identifiant \u00e0 notre place.<\/li>\n
      2. Lors de la cr\u00e9ation d’un lock, utiliser opType: Create<\/code> pour \u00eatre s\u00fbr qu’aucun document n’existe pour un m\u00eame identifiant. Cela permet d’\u00e9viter qu’un enregistrement n’ait \u00e9t\u00e9 cr\u00e9\u00e9 entre le moment o\u00f9 on regarde si un lock existe et celui o\u00f9 on cr\u00e9e le document de lock.<\/li>\n<\/ol>\n

        LockRepository<\/h2>\n

        Voici une potentielle impl\u00e9mentation pour un repository CRUD de Lock:<\/p>\n

        \npublic Optional findById(String category, String id)  throws IOException {\n        GetRequest getRequest = new GetRequest.Builder()\n                .index(\"locks\")\n                .id(id)\n                .build();\n\n        GetResponse getResponse = client.get(getRequest, Lock.class);\n        return Optional.ofNullable(getResponse.source());\n}\n\npublic boolean create(Lock newLock) throws IOException {\n        try {\n                \/\/ we use OptType.Create, so if a doc already exists, it will refuse to index a new one.\n                IndexRequest request = new IndexRequest.Builder()\n                        .index(\"locks\")\n                        .id(newLock.uid())\n                        .document(newLock)\n                        .opType(OpType.Create)\n                        .build();\n                client.index(request);\n                return true;\n        } catch (IOException e) {\n                \/\/ for conflicts, we return false to indicate that we were not able to create the lock\n                if (e instanceof ResponseException respException && \n                                respException.getResponse().getStatusLine().getStatusCode() == 409) {\n                        return false;\n                }\n                throw e;\n        }\n}\n\npublic void deleteById(String category, String id) throws IOException {\n        DeleteRequest request = new DeleteRequest.Builder()\n                .index(\"locks\")\n                .id(IdUtils.fromParts(category, id))\n                .build();\n\n        client.delete(request);\n}\n<\/pre>\n
        LockService<\/h2>\n
        Nous allons maintenant impl\u00e9menter un LockService<\/code> qui a une m\u00e9thode qui permet d’ex\u00e9cuter un Runnable<\/code> gard\u00e9 par un lock pour simuler une transaction.<\/p>\n
        Le principe est le suivant :<\/p>\n