Yandex cloud diagram

diagram.py

from diagrams import Diagram
from diagrams import Group
from diagrams.yc.infrastructure import Compute
from diagrams.yc.serverless import ServerlessFunctions
from diagrams.yc.serverless import ServerlessTriggers
from diagrams.yc.serverless import YMQ

with Diagram("Create Snapshots", show=False, direction="LR", curvestyle="polyline"):
    cron = ServerlessTriggers("Cron Trigger")
    spawn = ServerlessFunctions("Spawn Function")
    ymq = YMQ("YMQ")
    queue_trigger = ServerlessTriggers("Queue Trigger")

    with Group("Snapshot Functions", direction="TB"):
        snapshot_functions = [ServerlessFunctions() for i in range(3)]

    snapshot_serv = Compute("Snapshot\nService")

    cron >> spawn >> ymq >> queue_trigger

    queue_trigger >> snapshot_functions >> snapshot_serv