Configura las notificaciones de Pub/Sub de DICOM

En esta página, se describe cómo usar Pub/Sub para recibir notificaciones sobre acontecimientos clínicos en un almacén de DICOM. Puedes recibir notificaciones de Pub/Sub cuando se almacena una instancia de DICOM nueva en un almacén de DICOM o que se importan desde Cloud Storage.

Puedes usar las notificaciones de Pub/Sub para varios fines, como que activan el procesamiento posterior o el análisis de datos nuevos. Por ejemplo, un de aprendizaje automático pueden recibir notificaciones cuando haya nuevos datos disponibles para el entrenamiento y generar información útil para mejorar la atención al paciente.

En la siguiente figura, se muestra cómo se generan las notificaciones de Pub/Sub y publicados.

Figura 1. Recibir notificaciones de Pub/Sub sobre eventos clínicos en un almacén de DICOM

En la Figura 1, se muestran los siguientes pasos:

1. Un emisor realiza una solicitud para almacenar o importar una instancia de DICOM.
2. El almacén de DICOM recibe la solicitud, crea Pub/Sub y lo envía al tema de Pub/Sub configurado en el almacén de DICOM.
3. Pub/Sub reenvía el mensaje a las suscripciones adjuntas. al tema.
4. Los suscriptores reciben el mensaje de su suscripción. Cada suscripción puede tener uno o más suscriptores para aumentar el paralelismo.

Antes de comenzar

1. Crea un tema.
2. Crea una suscripción de extracción.

Agrega permisos de publicador de Pub/Sub

Para publicar mensajes de la API de Cloud Healthcare en Pub/Sub, debes hacer lo siguiente: debes agregar el rol pubsub.publisher al La cuenta de servicio del agente de servicio de Cloud Healthcare de tu proyecto. Para obtener más información, consulta Permisos de Pub/Sub de almacén de FHIR, FHIR y HL7v2.

Formato y contenido de las notificaciones

Una notificación de Pub/Sub contiene un Message que incluye información importante sobre el acontecimiento clínico. Las notificaciones de Pub/Sub de DICOM no Incluye un campo attributes. El objeto Message se ve similar a lo siguiente:

{
  "message": {
    "data": "BASE_64_ENCODED_DATA",
    "messageId": "MESSAGE_ID",
    "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
  }
}

El valor del campo data es el siguiente identificador como una cadena codificada en base 64: projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/dicomStores/DICOM_STORE_ID/dicomWeb/studies/STUDY_UID/series/SERIES_UID/instances/INSTANCE_UID

Para obtener más información sobre los campos incluidos en cada mensaje de Pub/Sub, consulta consulta ReceivedMessage y PubsubMessage.

Configurar y ver notificaciones

Esta sección describe cómo habilitar las notificaciones de Pub/Sub en almacenar, importar o almacenar una instancia de DICOM para publicar una notificación y verá la notificación.

Configura el almacén de DICOM

Permisos necesarios para esta tarea

Para realizar esta tarea, debes tener los siguientes permisos o los siguientes roles de Identity and Access Management (IAM):

Permisos

• healthcare.dicomStores.update

Funciones

• Administrador de almacenes de Healthcare DICOM (roles/healthcare.dicomStoreAdmin)

En los siguientes ejemplos, se muestra cómo habilitar las notificaciones de Pub/Sub en un almacén de DICOM cuando se almacena una instancia de DICOM nueva o se importa desde Cloud Storage.

REST

Usa el método projects.locations.datasets.dicomStores.patch.

El NotificationConfig.sendForBulkImport el valor es true, por lo que se envían notificaciones cuando se importan datos desde Cloud Storage.

Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:

• PROJECT_IDEl ID de tu proyecto de Google Cloud.
• LOCATION: La ubicación del conjunto de datos
• DATASET_ID: El conjunto de datos superior del almacén de DICOM
• DICOM_STORE_ID: El ID del almacén de DICOM
• PUBSUB_TOPIC: Es un tema de Pub/Sub en el que se publican mensajes cuando ocurre un evento en un almacén de datos.

Cuerpo JSON de la solicitud:

{
  "notificationConfig": {
    "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC",
    "sendForBulkImport": "true"
  }
}

Para enviar tu solicitud, elige una de estas opciones:

curl

Nota: Con el siguiente comando, se supone que accediste a la CLI de gcloud con tu cuenta de usuario a través de la ejecución de gcloud init o gcloud auth login, o a través del uso de Cloud Shell, que accede de forma automática a la CLI de gcloud. Para comprobar la cuenta activa actual, ejecuta gcloud auth list.

Guarda el cuerpo de la solicitud en un archivo llamado request.json. Ejecuta el comando siguiente en la terminal para crear o reemplazar este archivo en el directorio actual:

cat > request.json << 'EOF'
{
  "notificationConfig": {
    "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC",
    "sendForBulkImport": "true"
  }
}
EOF

Luego, ejecuta el siguiente comando para enviar tu solicitud de REST:

curl -X PATCH \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/dicomStores/DICOM_STORE_ID?updateMask=notificationConfig"

PowerShell

Nota: En el siguiente comando, se supone que accediste a la CLI de gcloud con tu cuenta de usuario a través de la ejecución de gcloud init o gcloud auth login . Para comprobar la cuenta activa actual, ejecuta gcloud auth list.

Guarda el cuerpo de la solicitud en un archivo llamado request.json. Ejecuta el comando siguiente en la terminal para crear o reemplazar este archivo en el directorio actual:

@'
{
  "notificationConfig": {
    "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC",
    "sendForBulkImport": "true"
  }
}
'@  | Out-File -FilePath request.json -Encoding utf8

Luego, ejecuta el siguiente comando para enviar tu solicitud de REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method PATCH `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/dicomStores/DICOM_STORE_ID?updateMask=notificationConfig" | Select-Object -Expand Content

Explorador de API

Copia el cuerpo de la solicitud y abre la página de referencia del método. El panel del Explorador de API se abre en la parte derecha de la página. Puedes interactuar con esta herramienta para enviar solicitudes. Pega el cuerpo de la solicitud en esta herramienta, completa cualquier otro campo obligatorio y haz clic en Ejecutar.

Deberías recibir una respuesta similar a la que figura a continuación.

Si configuraste algún campo en el recurso DicomStore, también aparecerá en la respuesta.

Respuesta

{
  "name": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/dicomStores/DICOM_STORE_ID",
  "notificationConfig": {
    "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC",
    "sendForBulkImport": "true"
  },
}

gcloud

Ejecuta el comando gcloud healthcare dicom-stores update.

Antes de usar cualquiera de los datos de comando a continuación, realiza los siguientes reemplazos:

• PROJECT_IDEl ID de tu proyecto de Google Cloud.
• LOCATION: La ubicación del conjunto de datos
• DATASET_ID: El conjunto de datos superior del almacén de DICOM
• DICOM_STORE_ID: El ID del almacén de DICOM
• PUBSUB_TOPIC: Es un tema de Pub/Sub en el que se publican mensajes cuando ocurre un evento en un almacén de datos.

Ejecuta el siguiente comando:

Linux, macOS o Cloud Shell

Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init o gcloud auth login y gcloud config set project.

gcloud healthcare dicom-stores update DICOM_STORE_ID \
  --dataset=DATASET_ID \
  --location=LOCATION \
  --pubsub-topic=projects/PROJECT_ID/topics/PUBSUB_TOPIC \
  --send-for-bulk-import

Windows (PowerShell)

Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init o gcloud auth login y gcloud config set project.

gcloud healthcare dicom-stores update DICOM_STORE_ID `
  --dataset=DATASET_ID `
  --location=LOCATION `
  --pubsub-topic=projects/PROJECT_ID/topics/PUBSUB_TOPIC `
  --send-for-bulk-import

Windows (cmd.exe)

Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init, o gcloud auth login y gcloud config set project.

gcloud healthcare dicom-stores update DICOM_STORE_ID ^
  --dataset=DATASET_ID ^
  --location=LOCATION ^
  --pubsub-topic=projects/PROJECT_ID/topics/PUBSUB_TOPIC ^
  --send-for-bulk-import

Deberías recibir una respuesta similar a la que figura a continuación:

Respuesta

Updated dicomStore [DICOM_STORE_ID].
...
name: projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/dicomStores/DICOM_STORE_ID
notificationConfig:
  pubsubTopic: projects/PROJECT_ID/topics/PUBSUB_TOPIC
  sendForBulkImport: true

Almacenar o importar una instancia de DICOM y ver la notificación de Pub/Sub

Permisos necesarios para esta tarea

Para realizar esta tarea, debes tener los siguientes permisos o los siguientes roles de Identity and Access Management (IAM):

Permisos

• healthcare.dicomStores.dicomWebWrite para almacenar instancias de DICOM en el almacén de DICOM solicitado.
• healthcare.dicomStores.import para importar instancias de DICOM al almacén de DICOM solicitado.

Funciones

• Editor de DICOM de atención médica (roles/healthcare.dicomEditor)

Para almacenar o importar una instancia de DICOM y extraer el mensaje de Pub/Sub generado, sigue estos pasos: completa los siguientes pasos:

1. Almacenar o importar una instancia de DICOM. La solicitud hace que la API de Cloud Healthcare publique un al tema de Pub/Sub configurado.

2. Extrae el mensaje. Si importas varios Para las instancias de DICOM en una sola solicitud, se genera un mensaje para cada una.

   Para ver los permisos de Identity and Access Management necesarios Para los mensajes de Pub/Sub, consulta Control de acceso para Pub/Sub.

   REST

   Usa el método projects.subscriptions.pull. En el siguiente ejemplo, se usa el parámetro de consulta ?maxMessages=10 para especifica la cantidad máxima de mensajes que se mostrarán en la solicitud. Ajusta este valor según tu caso de uso.

   Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:

   • PROJECT_IDEl ID de tu proyecto de Google Cloud.
   • PUBSUB_SUBSCRIPTION_ID: Es el ID de la suscripción adjunta al tema de Pub/Sub configurado en el almacén de DICOM.

   Para enviar tu solicitud, elige una de estas opciones:

   curl

   Nota: Con el siguiente comando, se supone que accediste a la CLI de gcloud con tu cuenta de usuario a través de la ejecución de gcloud init o gcloud auth login, o a través del uso de Cloud Shell, que accede de forma automática a la CLI de gcloud. Para comprobar la cuenta activa actual, ejecuta gcloud auth list.

   Ejecuta el siguiente comando:

   curl -X POST \
        -H "Authorization: Bearer $(gcloud auth print-access-token)" \
        -H "Content-Type: application/json; charset=utf-8" \
        -d "" \
        "https://pubsub.googleapis.com/v1/projects/PROJECT_ID/subscriptions/PUBSUB_SUBSCRIPTION_ID:pull?maxMessages=10"

   PowerShell

   Nota: En el siguiente comando, se supone que accediste a la CLI de gcloud con tu cuenta de usuario a través de la ejecución de gcloud init o gcloud auth login . Para comprobar la cuenta activa actual, ejecuta gcloud auth list.

   Ejecuta el siguiente comando:

   $cred = gcloud auth print-access-token
   $headers = @{ "Authorization" = "Bearer $cred" }
   
   Invoke-WebRequest `
       -Method POST `
       -Headers $headers `
       -Uri "https://pubsub.googleapis.com/v1/projects/PROJECT_ID/subscriptions/PUBSUB_SUBSCRIPTION_ID:pull?maxMessages=10" | Select-Object -Expand Content

   Explorador de API

   Abre el página de referencia del método. El panel del Explorador de API se abre en la parte derecha de la página. Puedes interactuar con esta herramienta para enviar solicitudes. Completa los campos obligatorios y haz clic en Ejecutar.

   Deberías recibir una respuesta JSON similar a la que se muestra a continuación:

   Respuesta

   {
     "receivedMessages": [
       {
         "ackId": "RFAGFixdRkhRNxkIaFEOT14jPzUgKEUaAggUBXx9cEFLdVhUcGhRDRlyfWB9bQ5GAgpGWixfURsHaE5tdR",
         "ackStatus": "SUCCESS",
         "message": {
           "data": "cHJvamVjdHMvbXlwcm9qZWN0L2xvY2F0aW9ucy91cy1jZW50cmFsMS9kYXRhc2V0cy9teS1kYXRhc2V0L2RpY29tU3RvcmVzL215LWRpY29tLXN0b3JlL2RpY29tV2ViL3N0dWRpZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjExMTM5NjM5OTM2MTk2OTg5ODIwNTM2NDQwMDU0OTc5OTI1Mjg1NzYwNC9zZXJpZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjE5NTYyODIxMzY5NDMwMDQ5ODk0Njc2MDc2NzQ4MTI5MTI2MzUxMTcyNC9pbnN0YW5jZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjE1Mzc1MTAwOTgzNTEwNzYxNDY2NjgzNDU2MzI5NDY4NDMzOTc0NjQ4MA==",
           "messageId": "7586159156345265",
           "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
         }
       }
     ]
   }
   

   gcloud

   Ejecuta el comando gcloud pubsub subscriptions pull:

   En la muestra, se usan las siguientes marcas de Google Cloud CLI:

   • --limit=10: Muestra un máximo de 10 mensajes. Ajusta este valor según tu caso de uso.
   • --format=json: Renderiza el resultado como JSON.
   • --auto-ack: Confirma automáticamente cada mensaje extraído.

   Antes de usar cualquiera de los datos de comando a continuación, realiza los siguientes reemplazos:

   • PROJECT_IDEl ID de tu proyecto de Google Cloud.
   • PUBSUB_SUBSCRIPTION_ID: Es el ID de la suscripción adjunta al tema de Pub/Sub configurado en el almacén de DICOM.

   Ejecuta el siguiente comando:

   Linux, macOS o Cloud Shell

   Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init o gcloud auth login y gcloud config set project.

   gcloud pubsub subscriptions pull \
       projects/PROJECT_ID/subscriptions/PUBSUB_SUBSCRIPTION_ID \
       --limit=10 \
       --auto-ack \
       --format=json
   

   Windows (PowerShell)

   Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init o gcloud auth login y gcloud config set project.

   gcloud pubsub subscriptions pull `
       projects/PROJECT_ID/subscriptions/PUBSUB_SUBSCRIPTION_ID `
       --limit=10 `
       --auto-ack `
       --format=json
   

   Windows (cmd.exe)

   Nota: Asegúrate de haber inicializado Google Cloud CLI con autenticación y un proyecto mediante la ejecución de gcloud init, o gcloud auth login y gcloud config set project.

   gcloud pubsub subscriptions pull ^
       projects/PROJECT_ID/subscriptions/PUBSUB_SUBSCRIPTION_ID ^
       --limit=10 ^
       --auto-ack ^
       --format=json
   

   Deberías recibir una respuesta similar a la que figura a continuación:

   [
     {
       "ackId": "RFAGFixdRkhRNxkIaFEOT14jPzUgKEUaAggUBXx9cEFLdVhUcGhRDRlyfWB9bQ5GAgpGWixfURsHaE5tdR",
       "ackStatus": "SUCCESS",
       "message": {
         "data": "cHJvamVjdHMvbXlwcm9qZWN0L2xvY2F0aW9ucy91cy1jZW50cmFsMS9kYXRhc2V0cy9teS1kYXRhc2V0L2RpY29tU3RvcmVzL215LWRpY29tLXN0b3JlL2RpY29tV2ViL3N0dWRpZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjExMTM5NjM5OTM2MTk2OTg5ODIwNTM2NDQwMDU0OTc5OTI1Mjg1NzYwNC9zZXJpZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjE5NTYyODIxMzY5NDMwMDQ5ODk0Njc2MDc2NzQ4MTI5MTI2MzUxMTcyNC9pbnN0YW5jZXMvMS4zLjYuMS40LjEuMTExMjkuNS41LjE1Mzc1MTAwOTgzNTEwNzYxNDY2NjgzNDU2MzI5NDY4NDMzOTc0NjQ4MA==",
         "messageId": "7586159156345265",
         "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
       }
     }
   ]
   

Política de almacenamiento de mensajes de Pub/Sub y API de Cloud Healthcare

Para asegurarte de que tus datos de la API de Cloud Healthcare y los datos asociados en los mensajes de Pub/Sub residan en la misma región, debes establecer una política de almacenamiento de mensajes de Pub/Sub.

Debes establecer de forma explícita la política de almacenamiento de mensajes en Pub/Sub tema configurado en el almacén de datos para garantizar que los datos permanezcan región. Por ejemplo, si el conjunto de datos de la API de Cloud Healthcare y el almacén de FHIR están en us-central1, la política de almacenamiento de mensajes solo debe permitir la región us-central1.

Para configurar una política de almacenamiento de mensajes, consulta Configura políticas de almacenamiento de mensajes.

Soluciona problemas de mensajes de Pub/Sub perdidos

Si no se puede publicar una notificación en Pub/Sub, se registra un error en Cloud Logging. Para obtener más información, consulta Visualiza los registros de errores en Cloud Logging.

Si la tasa de generación de errores excede un límite, los errores que superen el límite no se envían a Cloud Logging.

¿Qué sigue?

• Controla los picos transitorios con el control de flujo
• Soluciona los errores de los mensajes
• Cómo volver a reproducir y borrar definitivamente los mensajes
• Descripción general de la arquitectura de Pub/Sub