Notifications Pub/Sub FHIR

Cette page explique comment utiliser Pub/Sub pour recevoir des notifications lorsqu'un événement clinique se produit dans un datastore FHIR.

Vous pouvez utiliser les notifications Pub/Sub pour plusieurs cas d'utilisation, y compris déclenchant le traitement ou l'analyse en aval de nouvelles données. Par exemple, un modèle de machine learning peut recevoir des notifications lorsque de nouvelles données sont disponibles pour l'entraînement et générer des insights ou des prédictions pour améliorer la prise en charge des patients.

Présentation

Vous pouvez recevoir des notifications Pub/Sub lorsqu'une ressource FHIR est créés, mis à jour, corrigés ou supprimés dans un store FHIR. L'API Cloud Healthcare n'envoie pas de notifications lorsqu'une ressource FHIR est importée depuis Cloud Storage.

Pour recevoir des notifications, vous devez créer un sujet Pub/Sub et puis configurer le store FHIR pour qu'il envoie des notifications au sur un sujet.

Le schéma suivant montre comment les notifications Pub/Sub sont créées et livrés lorsqu'une ressource FHIR est créée dans un store FHIR à l'aide de la fhir.create . La procédure est la même lorsqu'une ressource FHIR est mise à jour, corrigée ou supprimée.

Notifications Pub/Sub FHIR

Figure 1 : Utiliser des notifications Pub/Sub pour les modifications apportées à un store FHIR.

La figure 1 illustre les étapes suivantes :

  1. Un appelant envoie une requête fhirStores.fhir.create pour créer une ressource FHIR.
  2. Le magasin FHIR reçoit la requête, crée un message Pub/Sub et l'envoie au sujet Pub/Sub configuré sur le magasin FHIR.
  3. Pub/Sub transfère le message aux abonnements associés sur le sujet.
  4. Les abonnés reçoivent une notification, sous la forme d'un message Pub/Sub, de leur abonnement. Chaque abonnement peut avoir un ou plusieurs abonnés pour accroître le parallélisme.

Configuration des notifications

Vous pouvez configurer les notifications Pub/Sub et leur comportement dans un objet FhirNotificationConfig sur un magasin FHIR. Chaque store FHIR peut avoir un seul FhirNotificationConfig configuré.

Le tableau suivant décrit les champs de l'objet FhirNotificationConfig.

Champ Description Exemple
pubsubTopic Sujet Pub/Sub à associer au magasin FHIR. Les notifications sont envoyées au sujet spécifié. projects/my-project/topics/my-topic
sendFullResource Indique si le contenu complet d'une ressource FHIR créée, mise à jour ou corrigée doit être inclus dans une notification. Ce champ n'a aucun effet sur les notifications envoyées lorsque des ressources FHIR sont supprimées. Pour inclure le contenu complet d'une ressource supprimée, définissez sendPreviousResourceOnDelete sur true. true
sendPreviousResourceOnDelete Indique si le contenu complet d'une ressource FHIR supprimée doit être inclus dans une notification. Ce champ n'a aucun effet sur les notifications envoyées lorsque des ressources FHIR sont créées, mises à jour ou corrigées. true

Format et contenu des notifications

Chaque notification Pub/Sub contient un objet message qui contient des informations sur l'événement clinique. L'objet message ressemble à ceci :

{
  "message": {
    "attributes": {
      "action": "ACTION",
      "lastUpdatedTime": "RFC_1123_FORMAT_DATETIME",
      "payloadType": "PAYLOAD_TYPE",
      "resourceType": "FHIR_RESOURCE_TYPE",
      "storeName": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID",
      "versionId": "VERSION_ID"
    },
    "data": "BASE_64_ENCODED_DATA",
    "messageId": "MESSAGE_ID",
    "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
  }
}

Pour en savoir plus sur les champs supplémentaires inclus dans chaque message Pub/Sub, consultez ReceivedMessage et PubsubMessage.

Le tableau suivant décrit chaque champ de l'objet attributes:

Attribut Description Exemple
action Action effectuée sur une ressource FHIR. Les valeurs possibles sont les suivantes :
  • CreateResource
  • PatchResource
  • UpdateResource
  • DeleteResource
 CreateResource
resourceType Type de ressource FHIR qui a été modifiée. Les valeurs possibles incluent tout type de ressource FHIR pris en charge dans l'API Cloud Healthcare. Patient
payloadType Type de charge utile du message (NameOnly ou FullResource). FullResource
storeName Nom complet de la ressource du store FHIR où l'action s'est produite. projects/my-project/locations/us/datasets/my-dataset/fhirStores/my-fhir-store
lastUpdatedTime Code temporel de la dernière modification de la ressource FHIR. L'horodatage utilise le format RFC 1123. Mon, 01 Jan 2020 00:00:00 UTC
versionId ID de la version la plus récente de la ressource FHIR sur laquelle l'action s'est produite. Pour en savoir plus sur les ID de version, consultez la section Répertorier les versions de ressources FHIR. MTY4MzA2MDQzOTI5NjIxMDAwMA

Le tableau suivant décrit les champs restants dans l'objet message:

Champ Description Exemple
data Chaîne encodée en base64 du nom ou du contenu de la ressource FHIR, en fonction des valeurs spécifiées dans FhirNotificationConfig.
messageId Identifiant du message Pub/Sub.
publishTime Heure à laquelle le serveur Pub/Sub a publié le message.

Spécifiez les informations à inclure dans les notifications

Les notifications Pub/Sub, comme indiqué dans la section Format et contenu des notifications, incluent un ensemble standard de champs. Vous pouvez inclure soit la ressource FHIR complète, soit simplement son nom dans chaque notification. Le nom de la ressource contient le chemin d'accès complet à la ressource et l'ID de la ressource au format suivant :

projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/RESOURCE_TYPE/RESOURCE_ID

Les informations sur les ressources FHIR sont stockées dans le champ data sous la forme d'une chaîne encodée en base64.

En incluant l'intégralité du contenu d'une ressource FHIR, vous n'avez pas besoin de pour interroger séparément Pub/Sub et l'API Cloud Healthcare pour connaître les ressources plus de détails.

Obtenir le nom de la ressource FHIR

Pour n’inclure que le nom d’une ressource FHIR lorsque vous créez, mettez à jour ou corriger la ressource, définissez sendFullResource sur false. Pour n'inclure le nom que lorsque vous supprimez une ressource FHIR, définissez De sendPreviousResourceOnDelete à false.

Lorsque vous affichez la notification, l'objet message se présente comme suit:

{
  "message": {
    "attributes": {
      "action": "{CreateResource|PatchResource|UpdateResource|DeleteResource}",
      "lastUpdatedTime": "RFC_1123_FORMAT_DATETIME",
      "payloadType": "NameOnly",
      "resourceType": "FHIR_RESOURCE_TYPE",
      "storeName": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID",
      "versionId": "VERSION_ID"
    },
    "data": "BASE64_ENCODED_FHIR_RESOURCE_NAME",
    "messageId": "MESSAGE_ID",
    "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
  }
}

Veuillez noter les points suivants dans la notification :

  • Le champ payloadType est défini sur NameOnly pour indiquer les éléments suivants concernant la requête :

    • Pour les opérations de création, de mise à jour et d'application de correctifs, sendFullResource est défini sur false.
    • Pour les opérations de suppression, sendPreviousResourceOnDelete est défini sur false.

  • Seul le nom de la ressource FHIR est inclus dans le champ data. Son nom est encodée en tant que chaîne encodée en base64.

Obtenir le contenu des ressources FHIR créées, mises à jour ou corrigées

Pour inclure le contenu complet d'une ressource FHIR lorsque vous la créez, la mettez à jour ou la corrigez, définissez sendFullResource sur true.

Ce comportement ne s'applique pas si vous supprimez une ressource FHIR. Si vous supprimez une ressource FHIR, et que sendFullResource est défini sur true, mais que sendPreviousResourceOnDelete est défini sur false, la notification est identique à celle que vous obtenez lorsque vous ne récupérez que le nom de la ressource FHIR. Pour inclure le contenu d'une ressource FHIR lorsqu'elle est supprimée, consultez Obtenir le contenu des ressources FHIR supprimées.

Lorsque vous affichez la notification, l'objet message se présente comme suit:

{
  "message": {
    "attributes": {
      "action": "{CreateResource|PatchResource|UpdateResource}",
      "lastUpdatedTime": "RFC_1123_FORMAT_DATETIME",
      "payloadType": "FullResource",
      "resourceType": "FHIR_RESOURCE_TYPE",
      "storeName": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID",
      "versionId": "VERSION_ID"
    },
    "data": "BASE64_ENCODED_FHIR_RESOURCE_CONTENTS",
    "messageId": "MESSAGE_ID",
    "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
  }
}

Notez les points suivants dans la notification:

  • payloadType est défini sur FullResource pour indiquer que sendFullResource est défini sur true. Le contenu complet de la ressource FHIR est inclus dans le champ data sous la forme d'une chaîne encodée en base64.
  • Le champ data contient le contenu de la ressource FHIR sous forme de chaîne encodée en base64.

Obtenir le contenu des ressources FHIR supprimées

Pour inclure le contenu complet d'une ressource FHIR lorsque vous la supprimez, définissez sendPreviousResourceOnDelete sur true.

Lorsque vous affichez la notification, l'objet message se présente comme suit:

{
  "message": {
    "attributes": {
      "action": "DeleteResource",
      "lastUpdatedTime": "RFC_1123_FORMAT_DATETIME",
      "payloadType": "FullResource",
      "resourceType": "FHIR_RESOURCE_TYPE",
      "storeName": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID",
      "versionId": "VERSION_ID"
    },
    "data": "BASE64_ENCODED_FHIR_RESOURCE_CONTENTS",
    "messageId": "MESSAGE_ID",
    "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
  }
}

Notez les valeurs des champs suivants :

  • payloadType est défini sur FullResource, même si sendFullResource est définie sur false.

    L'intégralité du contenu de la ressource FHIR est incluse dans le champ data sous forme de chaîne encodée en base64.

  • Le champ data contient le contenu de la ressource FHIR sous forme de chaîne encodée en base64 avant la suppression de la ressource.

Configurer et afficher les notifications FHIR

Les exemples suivants montrent comment afficher les messages Pub/Sub générés notification lorsqu'une ressource FHIR est créée dans un store FHIR.

Avant de commencer

Avant de configurer et d'utiliser les notifications Pub/Sub, effectuez la les sections suivantes:

Examiner le quota Pub/Sub

Familiarisez-vous avec les quotas et limites de Pub/Sub. Pour savoir comment afficher votre quota, demander une augmentation de quota et savoir ce qui se passe si vous épuisez votre quota, consultez la section Les quotas et leur utilisation.

Activer l'API Pub/Sub

Dans la console Google Cloud, activez l'API Pub/Sub :

Activer l'API

Configurer des autorisations Pub/Sub

Pour autoriser la publication de messages de l'API Cloud Healthcare vers Pub/Sub, vous devez ajouter le rôle pubsub.publisher au compte de service Agent de service Cloud Healthcare de votre projet. Consultez la section Autorisations Pub/Sub pour les magasins DICOM, FHIR et HL7v2 pour savoir comment ajouter le rôle requis.

Créer un sujet Pub/Sub

Pour créer un sujet, consultez Créer un sujet.

Un datastore individuel peut avoir son propre sujet Pub/Sub ou plusieurs datastores peuvent partager le même sujet.

Utilisez le format suivant pour spécifier le sujet Pub/Sub :

projects/PROJECT_ID/topics/TOPIC_NAME

PROJECT_ID est l'ID de votre projet Google Cloud. TOPIC_NAME est le nom du sujet Pub/Sub.

Créer un abonnement Pub/Sub

Pour recevoir des messages publiés dans un sujet, vous devez créer un abonnement Pub/Sub. Chaque sujet Pub/Sub nécessite au moins un abonnement Pub/Sub. L'abonnement connecte le sujet à une application d'abonnés, qui reçoit et traite les messages publiés dans le sujet.

Pour créer un abonnement et l'associer à un sujet Pub/Sub, consultez Créer des abonnements

Créer ou modifier un datastore FHIR

Créer ou modifier un store FHIR avec un objet FhirNotificationConfig configuré.

Les exemples suivants montrent comment modifier un datastore FHIR existant. Les champs sendFullResource et sendPreviousResourceOnDelete sont définis sur true, ce qui signifie que les notifications contiennent le contenu complet de la ressource FHIR lorsqu'une ressource est créée, mise à jour, corrigée ou supprimée.

REST

Pour modifier le magasin FHIR, utilisez la méthode projects.locations.datasets.fhirStores.patch.

Avant d'utiliser les données de requête ci-dessous, effectuez les remplacements suivants :

  • PROJECT_ID : ID de votre projet Google Cloud
  • LOCATION : emplacement de l'ensemble de données
  • DATASET_ID : ensemble de données parent du magasin FHIR.
  • FHIR_STORE_ID : ID du magasin FHIR.
  • PUBSUB_TOPIC_ID : ID du sujet Pub/Sub

Corps JSON de la requête : 

{
  "notificationConfigs": [
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC_ID",
      "sendFullResource": true,
      "sendPreviousResourceOnDelete": true
    }
  ]
}

Pour envoyer votre requête, choisissez l'une des options suivantes :

curl

Enregistrez le corps de la requête dans un fichier nommé request.json. Exécutez la commande suivante dans le terminal pour créer ou écraser ce fichier dans le répertoire actuel : 

cat > request.json << 'EOF'
{
  "notificationConfigs": [
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC_ID",
      "sendFullResource": true,
      "sendPreviousResourceOnDelete": true
    }
  ]
}
EOF

Exécutez ensuite la commande suivante pour envoyer votre requête 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/fhirStores/FHIR_STORE_ID?updateMask=notificationConfigs"

PowerShell

Enregistrez le corps de la requête dans un fichier nommé request.json. Exécutez la commande suivante dans le terminal pour créer ou écraser ce fichier dans le répertoire actuel : 

@'
{
  "notificationConfigs": [
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/PUBSUB_TOPIC_ID",
      "sendFullResource": true,
      "sendPreviousResourceOnDelete": true
    }
  ]
}
'@  | Out-File -FilePath request.json -Encoding utf8

Exécutez ensuite la commande suivante pour envoyer votre requête 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/fhirStores/FHIR_STORE_ID?updateMask=notificationConfigs" | Select-Object -Expand Content

Vous devriez recevoir une réponse JSON de ce type :

Créer une ressource FHIR

Créez une ressource FHIR dans le magasin FHIR. La requête déclenche la publication d'un message par l'API Cloud Healthcare dans le sujet Pub/Sub configuré.

Afficher la notification Pub/Sub

Affichez le message publié dans le sujet Pub/Sub. Le message suivant a été généré à la création d'une ressource Patient dans un magasin FHIR.

Dans l'exemple de résultat, le contenu de la ressource FHIR est encodé en base64 dans le champ data. Vous devez décoder la valeur encodée en base64 pour obtenir le contenu. La plupart des plates-formes et des systèmes d'exploitation disposent d'outils de décodage du texte base64.

REST

Pour afficher le message publié dans le sujet Pub/Sub, utilisez la méthode projects.subscriptions.pull . L'exemple suivant utilise le paramètre de requête ?maxMessages=10 pour spécifier le nombre maximal de messages à renvoyer dans la requête. Vous pouvez ajuster la valeur en fonction de vos besoins.

Avant d'utiliser les données de requête ci-dessous, effectuez les remplacements suivants :

  • PROJECT_ID : ID de votre projet Google Cloud
  • PUBSUB_SUBSCRIPTION_ID : ID de l'abonnement associé au sujet Pub/Sub configuré dans le magasin FHIR

Pour envoyer votre requête, choisissez l'une des options suivantes :

curl

Exécutez la commande suivante :

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

Exécutez la commande suivante :

$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

Vous devriez recevoir une réponse JSON de ce type :

gcloud

Pour afficher le message publié dans le sujet Pub/Sub, exécutez la commande gcloud pubsub subscriptions pull .

L'exemple utilise les options Google Cloud CLI suivantes :

  • --format=json : affiche la sortie au format JSON.
  • --auto-ack: accuser réception automatiquement de chaque message récupéré.

Avant d'utiliser les données de la commande ci-dessous, effectuez les remplacements suivants :

  • PROJECT_ID : ID de votre projet Google Cloud
  • PUBSUB_SUBSCRIPTION_ID : ID de l'abonnement associé au sujet Pub/Sub configuré dans le magasin FHIR

Exécutez la commande suivante :

Linux, macOS ou Cloud Shell

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

Windows (PowerShell)

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

Windows (cmd.exe)

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

Vous devriez obtenir un résultat semblable à celui-ci :

[
  {
    "ackId": "RFAGFixdRkhRNxkIaFEOT14jPzUgKEUaAggUBXx9cEFLdVhUcGhRDRlyfWB9bQ5GAgpGWixfURsHaE5tdR",
    "ackStatus": "SUCCESS",
    "message": {
      "attributes": {
        "action": "CreateResource",
        "lastUpdatedTime": "Mon, 01 Jan 2020 00:00:00 UTC",
        "payloadType": "FullResource",
        "resourceType": "Patient",
        "storeName": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID",
        "versionId": "MTY4MzA2MDQzOTI5NjIxMDAwMA"
      },
      "data": "wogICJiaXJ0aERhdGUiOiAiMTk3MC0wMS0wMSIsCiAgImdlbmRlciI6ICJmZW1hbGUiLAogICJpZCI6ICIyYmMwODg4Yi00MGRmLTQwYzctOWRhYi0wMzc4YTFiZWE0MGIiLAogICJtZXRhIjogewogICAgImxhc3RVcGRhdGVkIjogIjIwMjMtMDUtMDJUMjA6NDc6MTkuMjk2MjEwKzAwOjAwIiwKICAgICJ2ZXJzaW9uSWQiOiAiTVRZNE16QTJNRFF6T1RJNU5qSXhNREF3TUEiCiAgfSwKICAibmFtZSI6IFsKICAgIHsKICAgICAgImZhbWlseSI6ICJTbWl0aCIsCiAgICAgICJnaXZlbiI6IFsKICAgICAgICAiRGFyY3kiCiAgICAgIF0sCiAgICAgICJ1c2UiOiAib2ZmaWNpYWwiCiAgICB9CiAgXSwKICAicmVzb3VyY2VUeXBlIjogIlBhdGllbnQiCn0=",
      "messageId": "7586159156345265",
      "publishTime": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ"
    }
  }
]

Comportement lorsqu'une ressource FHIR est trop volumineuse ou que le trafic est important

Si la taille d'une ressource FHIR est trop importante ou si l'API Cloud Healthcare serveurs rencontrent un trafic élevé, le champ attributes risque ne contiennent que le nom de la ressource au lieu du contenu complet de la ressource. Ce comportement se produit même si sendFullResource et sendPreviousResourceOnDelete est défini sur true.

Pour vérifier si une notification Pub/Sub contient la ressource FHIR complète, vérifiez le champ payloadType dans la réponse à l'affichage de la notification. Si payloadType est défini sur nameOnly, le Le champ attributes n'a pas rempli entièrement les données de la ressource FHIR. Vous devez ensuite obtenir manuellement le contenu de la ressource FHIR à partir du store FHIR à la place du message Pub/Sub.

Règles de stockage des messages de l'API Cloud Healthcare et Pub/Sub

Pour vous assurer que les données de l'API Cloud Healthcare et les données associées dans les messages Pub/Sub se trouvent dans la même région, vous devez définir une règle de stockage des messages Pub/Sub.

Vous devez définir explicitement la règle de stockage des messages sur le sujet Pub/Sub configuré sur le magasin de données pour vous assurer que les données restent dans la même région. Par exemple, si l'ensemble de données et le magasin FHIR de l'API Cloud Healthcare sont dans la région us-central1, la règle de stockage des messages doit autoriser uniquement la région us-central1.

Pour configurer une règle de stockage des messages, consultez la page Configurer des règles de stockage des messages.

Résoudre les problèmes de messages Pub/Sub manqués

Si une notification ne peut pas être publiée dans Pub/Sub, une erreur est consignée dans Cloud Logging. Pour en savoir plus, consultez la section Afficher les journaux d'erreurs dans Cloud Logging.

Si le taux de génération d'erreurs dépasse une limite, les erreurs dépassant cette limite ne sont pas envoyées à Cloud Logging.

Afficher les notifications FHIR à l'aide de la configuration NotificationConfig (obsolète)

La ressource FhirStore contient un objet NotificationConfig dans lequel vous pouvez spécifier un sujet Pub/Sub. Les modifications apportées aux ressources FHIR contiennent toujours l'identifiant suivant dans le Champ data du message Pub/Sub:

projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/RESOURCE_TYPE/RESOURCE_ID

L'ensemble de paires clé / valeur suivant est toujours inclus dans le champ attributes du message:

Nom de l'attribut Valeurs possibles Exemple Description
action
  • CreateResource
  • PatchResource
  • UpdateResource
  • DeleteResource
 CreateResource Type d'événement qui vient de se produire.
resourceType Tout type de ressource FHIR. Patient Type de ressource qui a été modifié.

Étape suivante