View a markdown version of this page

Execute um processo de daemon em segundo plano a partir do ambiente de filas - Deadline Cloud
Pré-requisitosExecute a amostra do daemonExibir os registros do daemon

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Execute um processo de daemon em segundo plano a partir do ambiente de filas

Em muitos casos de uso de renderização, carregar os dados do aplicativo e da cena pode levar um tempo significativo. Se uma tarefa os recarregar para cada quadro, ela passará a maior parte do tempo sobrecarregada. Geralmente, é possível carregar o aplicativo uma vez como um processo daemon em segundo plano, fazer com que ele carregue os dados da cena e, em seguida, envie comandos via comunicação entre processos (IPC) para realizar as renderizações.

Muitas das integrações de código aberto do Deadline Cloud usam esse padrão. O projeto Open Job Description fornece uma biblioteca de tempo de execução de adaptadores com padrões de IPC confiáveis em todos os sistemas operacionais compatíveis.

Para demonstrar esse padrão, há um pacote de trabalho de amostra independente que usa código Python e bash para implementar um daemon em segundo plano e o IPC para tarefas de comunicação com ele. O daemon é implementado em Python e escuta um sinal POSIX SIGUSR1 para saber quando processar uma tarefa. Os detalhes da tarefa são passados para o daemon em um arquivo JSON específico e os resultados da execução da tarefa são retornados como outro arquivo JSON.

Pré-requisitos

Execute as etapas a seguir para executar o pacote de tarefas de amostra com um processo daemon do repositório github de amostras do Deadline Cloud.

  1. Se você não tiver um farm do Deadline Cloud com uma fila e uma frota Linux associada, siga a experiência de integração guiada no console do Deadline Cloud para criar um com as configurações padrão.

  2. Se você não tiver o Deadline Cloud CLI e o monitor Deadline Cloud em sua estação de trabalho, siga as etapas em Configurar remetentes do Deadline Cloud no guia do usuário.

  3. Use git para clonar o GitHub repositório de amostras do Deadline Cloud. 

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

Execute a amostra do daemon

  1. Use o Deadline Cloud CLI para enviar a job_env_daemon_process amostra.

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

  2. No aplicativo de monitoramento Deadline Cloud, você verá o novo trabalho e poderá monitorar seu progresso. Quando a Linux frota associada à fila tiver um trabalhador disponível para executar a tarefa, ela será concluída em cerca de um minuto. Com uma das tarefas selecionadas, escolha a opção Exibir registros no menu superior direito do painel de tarefas.

    À direita, há duas ações de sessão, Inicializar DaemonProcess e Executar tarefa. O visualizador de registros no centro da janela corresponde à ação da sessão selecionada à direita.

    Selecione a opção Exibir registros de todas as tarefas. A linha do tempo mostra o restante das tarefas executadas como parte da sessão e a Shut down DaemonProcess ação que saiu do ambiente.

Exibir os registros do daemon

  1. Nesta seção, você usa o monitor Deadline Cloud para comparar as ações da sessão com o local onde elas estão definidas no modelo de trabalho. Continua da seção anterior.

    Abra o arquivo job_env_daemon_process/template .yaml em um editor de texto. Compare as ações da sessão com o local onde elas estão definidas no modelo de trabalho.

  2. Selecione a ação da Launch DaemonProcess sessão no monitor Deadline Cloud. Você verá a saída do log da seguinte forma.

     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

    As linhas a seguir do modelo de trabalho especificaram essa ação.

       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. Selecione uma das ações de sessão Task run: N no monitor Deadline Cloud. Você verá a saída do log da seguinte forma.

    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 ----------------------------------------------

    As seguintes linhas do modelo de trabalho são o que especificou essa ação. ```etapas: 

     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