Skip to main content

orchestrator - convenient configuration of interaction between services in microservice architecture

Installation

pip install orchestrator-service

Problem

The application has a lot of services for performing tasks. Each service performs its own task. Different services bundles are used to perform different tasks.

Example:

Task Service execution sequence
Task1 service1 -> service2 -> service3
Task2 service2 -> service4 -> service1
... ...
TaskN service3 -> service2 -> ... -> serviceM

In order to centralized control the permissible sequence of execution of services for different tasks, we offer you an orchestrator.

                                      ________________
                                      |              |
                                      |   service2   |
                                      |______________|
                                             |
                                             |                                       
                                         ____|____                                       
                                         | queue |                                       
                                         |_______|  
                                             |                                                                                                                        
                                             |
________________                       ________________                       ________________
|              |       _________       |              |       _________       |              |
|   service1   | ----->| queue | ----->| orchestrator | ----->| queue | ----->|   serviceN   |
|______________|       |_______|       |______________|       |_______|       |______________|
                                             |
                                             |                                       
                                         _________                                       
                                         | queue |                                       
                                         |_______|  
                                             |
                                             |                                                                                                                        
                                      _______|________
                                      |              |
                                      |   service3   |
                                      |______________|

Pros:

  • centralized control
  • easy expansion
  • easy setup
  • reuse of services in different tasks

What is needed to be implemented in current architectures

  • implement block for the corresponding service
  • add a source to messages (the name of the service to which the corresponding block in the orchestrator should be)
  • add a flow to messages (similarly as the source)
  • redefine blocks for the desired type of queue

Bonus:

  • service for build microservice architecture.

Future plans:

  • add async functions to orchestrator
  • add handler for incorrect messages to service

more details in examples

Metadata

Release files for orchestrator-service 0.0.15

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for orchestrator-service 0.0.15
File Size Uploaded
orchestrator_service-0.0.15.tar.gz 16.4 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for orchestrator-service 0.0.15
File Interpreter ABI Platform
orchestrator_service-0.0.15-py3-none-any.whl Python 3 none any Details

Total release size: 38.5 kB

Release files / orchestrator_service-0.0.15.tar.gz

Download URL orchestrator_service-0.0.15.tar.gz
Size 16.4 kB
Tags Source
SHA-256 checksum
How to use checksums
65a07164d168f3f4b5eddd8fb28b2f796b21b3e4ebd04a3dbf5d7d6ed3faacda
BLAKE2b-256 checksum
How to use checksums
db49c502cc83186ce5143d084d9df738b4f577c082ee05357c50667cea87b6f7
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/3.3.0 pkginfo/1.7.0 requests/2.24.0 setuptools/54.2.0 requests-toolbelt/0.9.1 tqdm/4.49.0 CPython/3.7.9

Release files / orchestrator_service-0.0.15-py3-none-any.whl

Download URL orchestrator_service-0.0.15-py3-none-any.whl
Size 22.1 kB
Tags Python 3
SHA-256 checksum
How to use checksums
9f467e7c6b660bc74903d5b00721b69d350e1f8090821a141982b3d363eaf93b
BLAKE2b-256 checksum
How to use checksums
c9b2538a3c3496d1868973ceb6a370cc2010586a474607893d91f084122074a8
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/3.3.0 pkginfo/1.7.0 requests/2.24.0 setuptools/54.2.0 requests-toolbelt/0.9.1 tqdm/4.49.0 CPython/3.7.9

Release history Release notifications | RSS feed

This release

0.0.15 This release

2 release files

0.0.14

1 release file

0.0.13

1 release file

0.0.12

1 release file

0.0.11

1 release file

0.0.10

2 release files

0.0.9

1 release file

0.0.8

2 release files

0.0.7

2 release files

0.0.6

2 release files

0.0.5

2 release files

0.0.4

2 release files

0.0.3

2 release files

0.0.2

2 release files

0.0.1

1 release file

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page