View a markdown version of this page

Esegue un processo daemon in background dall'ambiente di coda - Deadline Cloud
PrerequisitiEsegui l'esempio del demoneVisualizza i log dei daemon

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Esegue un processo daemon in background dall'ambiente di coda

In molti casi d'uso del rendering, il caricamento dei dati dell'applicazione e della scena può richiedere molto tempo. Se un processo li ricarica per ogni fotogramma, dedicherà la maggior parte del suo tempo alle spese generali. Spesso è possibile caricare l'applicazione una sola volta come processo daemon in background, farle caricare i dati della scena e quindi inviarle comandi tramite comunicazione tra processi (IPC) per eseguire i rendering.

Molte delle integrazioni open source di Deadline Cloud utilizzano questo modello. Il progetto Open Job Description fornisce una libreria di runtime dell'adattatore con pattern IPC affidabili su tutti i sistemi operativi supportati.

Per dimostrare questo modello, è disponibile un job bundle di esempio autonomo che utilizza Python e codice bash per implementare un demone in background e l'IPC per consentire alle attività di comunicare con esso. Il demone è implementato in Python e ascolta un segnale POSIX SIGUSR1 per sapere quando elaborare un task. I dettagli dell'attività vengono passati al demone in un file JSON specifico e i risultati dell'esecuzione dell'attività vengono restituiti come un altro file JSON.

Prerequisiti

Esegui i passaggi seguenti per eseguire il pacchetto di job di esempio con un processo daemon dal repository github degli esempi di Deadline Cloud.

  1. Se non disponi di una farm Deadline Cloud con una coda e un parco Linux associato, segui l'esperienza di onboarding guidata nella console Deadline Cloud per crearne una con le impostazioni predefinite.

  2. Se non hai l'interfaccia a riga di comando di Deadline Cloud e il monitor Deadline Cloud sulla tua workstation, segui la procedura descritta nella sezione Configurazione dei mittenti di Deadline Cloud contenuta nella guida per l'utente.

  3. Utilizzalo git per clonare il repository di esempi di Deadline Cloud. GitHub 

    git clone https://github.com/aws-deadline/deadline-cloud-samples.git
 Cloning into 'deadline-cloud-samples'...
 ...
cd deadline-cloud-samples/job_bundles

Esegui l'esempio del demone

  1. Usa l'interfaccia a riga di comando di Deadline Cloud per inviare il job_env_daemon_process campione.

     git clone https://github.com/aws-deadline/deadline-cloud-samples.git
Cloning into 'deadline-cloud-samples'...
 ...
cd deadline-cloud-samples/job_bundles

  2. Nell'applicazione di monitoraggio Deadline Cloud, vedrai il nuovo lavoro e potrai monitorarne l'avanzamento. Una volta che la Linux flotta associata alla coda ha un lavoratore disponibile per eseguire l'attività del lavoro, il processo viene completato in circa un minuto. Con una delle attività selezionate, scegli l'opzione Visualizza registri nel menu in alto a destra del pannello delle attività.

    Sulla destra ci sono due azioni di sessione, Launch DaemonProcess ed Task run. Il visualizzatore di log al centro della finestra corrisponde all'azione della sessione selezionata sulla destra.

    Seleziona l'opzione Visualizza i registri per tutte le attività. La sequenza temporale mostra il resto delle attività eseguite come parte della sessione e l'Shut down DaemonProcessazione che è uscita dall'ambiente.

Visualizza i log dei daemon

  1. In questa sezione si utilizza il monitor Deadline Cloud per confrontare le azioni della sessione con il punto in cui sono definite nel modello di lavoro. Continua dalla sezione precedente.

    Apri il file job_env_daemon_process/template .yaml in un editor di testo. Confronta le azioni della sessione con il punto in cui sono definite nel modello di lavoro.

  2. Seleziona l'azione Launch DaemonProcess della sessione nel monitor Deadline Cloud. L'output del registro verrà visualizzato come segue.

     2024/07/17 16:27:20-07:00
 2024/07/17 16:27:20-07:00 ==============================================
 2024/07/17 16:27:20-07:00 --------- Entering Environment: DaemonProcess
 2024/07/17 16:27:20-07:00 ==============================================
 2024/07/17 16:27:20-07:00 ----------------------------------------------
 2024/07/17 16:27:20-07:00 Phase: Setup
 2024/07/17 16:27:20-07:00 ----------------------------------------------
 2024/07/17 16:27:20-07:00 Writing embedded files for Environment to disk.
 2024/07/17 16:27:20-07:00 Mapping: Env.File.Enter -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/enter-daemon-process-env.sh
 2024/07/17 16:27:20-07:00 Mapping: Env.File.Exit -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/exit-daemon-process-env.sh
 2024/07/17 16:27:20-07:00 Mapping: Env.File.DaemonScript -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/daemon-script.py
 2024/07/17 16:27:20-07:00 Mapping: Env.File.DaemonHelperFunctions -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/daemon-helper-functions.sh
 2024/07/17 16:27:20-07:00 Wrote: Enter -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/enter-daemon-process-env.sh
 2024/07/17 16:27:20-07:00 Wrote: Exit -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/exit-daemon-process-env.sh
 2024/07/17 16:27:20-07:00 Wrote: DaemonScript -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/daemon-script.py
 2024/07/17 16:27:20-07:00 Wrote: DaemonHelperFunctions -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/daemon-helper-functions.sh
 2024/07/17 16:27:20-07:00 ----------------------------------------------
 2024/07/17 16:27:20-07:00 Phase: Running action
 2024/07/17 16:27:20-07:00 ----------------------------------------------
 2024/07/17 16:27:20-07:00 Running command sudo -u job-user -i setsid -w /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/tmp_u8slys3.sh
 2024/07/17 16:27:20-07:00 Command started as pid: 2187
 2024/07/17 16:27:20-07:00 Output:
 2024/07/17 16:27:21-07:00 openjd_env: DAEMON_LOG=/sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/daemon.log
 2024/07/17 16:27:21-07:00 openjd_env: DAEMON_PID=2223
 2024/07/17 16:27:21-07:00 openjd_env: DAEMON_BASH_HELPER_SCRIPT=/sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/daemon-helper-functions.sh

    Le righe seguenti del modello di lavoro specificano questa azione.

       stepEnvironments:
   - name: DaemonProcess
     description: Runs a daemon process for the step's tasks to share.
     script:
       actions:
         onEnter:
           command: bash
           args:
           - "{{Env.File.Enter}}"
         onExit:
           command: bash
           args:
           - "{{Env.File.Exit}}"
       embeddedFiles:
       - name: Enter
         filename: enter-daemon-process-env.sh
         type: TEXT
         data: |
           #!/bin/env bash
           set -euo pipefail

           DAEMON_LOG='{{Session.WorkingDirectory}}/daemon.log'
           echo "openjd_env: DAEMON_LOG=$DAEMON_LOG"
           nohup python {{Env.File.DaemonScript}} > $DAEMON_LOG 2>&1 &
           echo "openjd_env: DAEMON_PID=$!"
           echo "openjd_env: DAEMON_BASH_HELPER_SCRIPT={{Env.File.DaemonHelperFunctions}}"

           echo 0 > 'daemon_log_cursor.txt'
     ...

  3. Seleziona una delle azioni Task run: N session nel monitor Deadline Cloud. L'output del registro verrà visualizzato come segue.

    2024/07/17 16:27:22-07:00
 2024/07/17 16:27:22-07:00 ==============================================
 2024/07/17 16:27:22-07:00 --------- Running Task
 2024/07/17 16:27:22-07:00 ==============================================
 2024/07/17 16:27:22-07:00 Parameter values:
 2024/07/17 16:27:22-07:00 Frame(INT) = 2
 2024/07/17 16:27:22-07:00 ----------------------------------------------
 2024/07/17 16:27:22-07:00 Phase: Setup
 2024/07/17 16:27:22-07:00 ----------------------------------------------
 2024/07/17 16:27:22-07:00 Writing embedded files for Task to disk.
 2024/07/17 16:27:22-07:00 Mapping: Task.File.Run -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/run-task.sh
 2024/07/17 16:27:22-07:00 Wrote: Run -> /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/embedded_fileswy00x5ra/run-task.sh
 2024/07/17 16:27:22-07:00 ----------------------------------------------
 2024/07/17 16:27:22-07:00 Phase: Running action
 2024/07/17 16:27:22-07:00 ----------------------------------------------
 2024/07/17 16:27:22-07:00 Running command sudo -u job-user -i setsid -w /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/tmpv4obfkhn.sh
 2024/07/17 16:27:22-07:00 Command started as pid: 2301
 2024/07/17 16:27:22-07:00 Output:
 2024/07/17 16:27:23-07:00 Daemon PID is 2223
 2024/07/17 16:27:23-07:00 Daemon log file is /sessions/session-972e21d98dde45e59c7153bd9258a64dohwg4yg1/daemon.log
 2024/07/17 16:27:23-07:00
 2024/07/17 16:27:23-07:00 === Previous output from daemon
 2024/07/17 16:27:23-07:00 ===
 2024/07/17 16:27:23-07:00
 2024/07/17 16:27:23-07:00 Sending command to daemon
 2024/07/17 16:27:23-07:00 Received task result:
 2024/07/17 16:27:23-07:00 {
 2024/07/17 16:27:23-07:00   "result": "SUCCESS",
 2024/07/17 16:27:23-07:00   "processedTaskCount": 1,
 2024/07/17 16:27:23-07:00   "randomValue": 0.2578537967668988,
 2024/07/17 16:27:23-07:00   "failureRate": 0.1
 2024/07/17 16:27:23-07:00 }
 2024/07/17 16:27:23-07:00
 2024/07/17 16:27:23-07:00 === Daemon log from running the task
 2024/07/17 16:27:23-07:00 Loading the task details file
 2024/07/17 16:27:23-07:00 Received task details:
 2024/07/17 16:27:23-07:00 {
 2024/07/17 16:27:23-07:00  "pid": 2329,
 2024/07/17 16:27:23-07:00  "frame": 2
 2024/07/17 16:27:23-07:00 }
 2024/07/17 16:27:23-07:00 Processing frame number 2
 2024/07/17 16:27:23-07:00 Writing result
 2024/07/17 16:27:23-07:00 Waiting until a USR1 signal is sent...
 2024/07/17 16:27:23-07:00 ===
 2024/07/17 16:27:23-07:00
 2024/07/17 16:27:23-07:00 ----------------------------------------------
 2024/07/17 16:27:23-07:00 Uploading output files to Job Attachments
 2024/07/17 16:27:23-07:00 ----------------------------------------------

    Le seguenti righe del modello di lavoro sono quelle che specificano questa azione. ```passaggi: 

     steps:
 - name: EnvWithDaemonProcess
   parameterSpace:
     taskParameterDefinitions:
     - name: Frame
       type: INT
       range: "{{Param.Frames}}"

   stepEnvironments:
     ...

   script:
     actions:
       onRun:
         timeout: 60
         command: bash
         args:
         - '{{Task.File.Run}}'
     embeddedFiles:
     - name: Run
       filename: run-task.sh
       type: TEXT
       data: |
         # This bash script sends a task to the background daemon process,
         # then waits for it to respond with the output result.

         set -euo pipefail

         source "$DAEMON_BASH_HELPER_SCRIPT"

         echo "Daemon PID is $DAEMON_PID"
         echo "Daemon log file is $DAEMON_LOG"

         print_daemon_log "Previous output from daemon"

         send_task_to_daemon "{\"pid\": $$, \"frame\": {{Task.Param.Frame}} }"
         wait_for_daemon_task_result

         echo Received task result:
         echo "$TASK_RESULT" | jq .

         print_daemon_log "Daemon log from running the task"

   hostRequirements:
     attributes:
     - name: attr.worker.os.family
       anyOf:
       - linux