Flux exploitation d’un film

Entité : MovieExploitation

Les informations d’une exploitation d’un film proviennent de plusieurs sources :

  • DB2 : Création et mise à jour

Import

as400.chf.ChFILCR

Flux d’import

sequenceDiagram participant TAS400 as as400.chf.ChFILCR participant JCentral as Job Central participant ES as ElasticSearch participant KS as KafkaStore TAS400->>JCentral: ChFilCr JCentral->>JCentral: ChFilCrToMovieExploitation JCentral->>ES: Persist JCentral->>KS: Persist

Topics

Les données qui transitent sont des entités MovieExploitation.

cineges.movieexploitation.saveLocal

Enregistre les informations d’une exploitation d’un film dans ES, puis les propage dans le topic et le store kafka cineges.distributionhome.data.

cineges.movieexploitation.data

Copie des entités MovieExploitation depuis ES.

cineges.movieexploitation.saveToComplexe

Topic repliqué du central au complexe.

cineges.movieexploitation.saveToCentral

Topic repliqué du complexe au central.

Fonctionnement

L’objet MovieExploitation peut être modifié depuis plusieurs endroits :

  • Les jobs d’import AS400

Central

//TODO

Complexe

//TODO