Omówienie etapów przetwarzania danych urządzeń usługi MedTech

Artykuł
11/08/2023

Ten artykuł zawiera omówienie etapów przetwarzania danych urządzenia w usłudze MedTech. Usługa MedTech przekształca dane urządzenia w obserwacje FHIR na potrzeby trwałości w usłudze FHIR®.

Przetwarzanie danych urządzenia MedTech odbywa się zgodnie z tymi etapami i w następującej kolejności:

Pozyskiwanie
Normalizacja — zastosowane mapowanie urządzeń.
Grupa — (opcjonalnie)
Przekształć — zastosowane mapowanie docelowe FHIR.
Persist

Pozyskiwanie

Pozyskiwanie to pierwszy etap, w którym komunikaty urządzeń są odbierane z centrum zdarzeń usługi Azure Event Hubs i natychmiast pobierane do usługi MedTech. Usługa Event Hubs obsługuje wysoką skalę i przepływność z możliwością odbierania i przetwarzania milionów komunikatów urządzeń na sekundę. Umożliwia również usłudze MedTech asynchroniczne korzystanie z komunikatów urządzenia, co pozwala na asynchroniczne oczekiwanie na urządzenia podczas przetwarzania komunikatów urządzenia. Tożsamość zarządzana przypisana przez system usługi MedTech i kontrola dostępu oparta na zasobach platformy Azure (Azure RBAC) są używane do bezpiecznego dostępu do centrum zdarzeń.

Uwaga

Format JSON jest obecnie jedynym obsługiwanym formatem dla danych komunikatów urządzenia.

Ważne

Jeśli zezwolisz na dostęp z wielu usług do centrum zdarzeń, wymagane jest, aby każda usługa ma własną grupę odbiorców centrum zdarzeń.

Grupy odbiorców umożliwiają wielu aplikacjom korzystającym z oddzielnego widoku strumienia zdarzeń oraz odczytywanie strumienia niezależnie we własnym tempie i z własnymi przesunięciami. Aby uzyskać więcej informacji, zobacz Grupy odbiorców.

Przykłady:

Dwie usługi MedTech, które uzyskują dostęp do tego samego centrum zdarzeń.
Usługa MedTech i aplikacja modułu zapisywania magazynu, która uzyskuje dostęp do tego samego centrum zdarzeń.

Normalizacji

Normalizacja to następny etap przetwarzania danych urządzenia przy użyciu wybranego przez użytkownika/utworzonego przez użytkownika zgodnego i prawidłowego mapowania urządzenia. Ten proces mapowania powoduje przekształcenie danych urządzenia w znormalizowany schemat. Proces normalizacji nie tylko upraszcza przetwarzanie danych urządzenia na późniejszych etapach, ale także umożliwia projekcję jednego komunikatu urządzenia w wiele znormalizowanych komunikatów. Na przykład urządzenie może wysyłać wiele ważnych oznak temperatury ciała, tętna, ciśnienia krwi i częstotliwości oddychania w jednym komunikacie urządzenia. Ten komunikat urządzenia tworzy cztery oddzielne obserwacje FHIR. Każda obserwacja FHIR będzie reprezentować inny ważny znak, a komunikat urządzenia jest przewidywany na cztery różne znormalizowane komunikaty.

Grupa — (opcjonalnie)

Grupa to kolejny opcjonalny etap, w którym znormalizowane komunikaty dostępne na etapie normalizacji usługi MedTech są pogrupowane przy użyciu trzech różnych parametrów:

Tożsamość urządzenia
Typy miary
Okres

Grupowanie tożsamości i typów pomiarów urządzenia jest opcjonalne i włączone przy użyciu typu miary SampledData . Typ miary SampledData zapewnia zwięzły sposób reprezentowania szeregów czasowych pomiarów z komunikatu urządzenia do obserwacji FHIR. W przypadku użycia typu miary SampledData pomiary można zgrupować w pojedynczą obserwację FHIR, która reprezentuje okres 1-godzinny lub okres 24-godzinny.

Przekształcanie

Przekształcenie to kolejny etap, w którym znormalizowane komunikaty są przetwarzane przy użyciu wybranego przez użytkownika/utworzonego przez użytkownika zgodnego i prawidłowego mapowania docelowego FHIR. Znormalizowane komunikaty są przekształcane w obserwacje FHIR, jeśli utworzono pasujące mapowanie miejsca docelowego FHIR. W tym momencie zasób Urządzenie wraz ze skojarzonym zasobem Pacjenta jest również pobierany z usługi FHIR przy użyciu identyfikatora urządzenia obecnego w komunikacie urządzenia. Te zasoby są dodawane jako odwołanie do tworzonej obserwacji FHIR.

Uwaga

Wszystkie wyszukiwania tożsamości są buforowane po rozwiązaniu, aby zmniejszyć obciążenie usługi FHIR. Jeśli planujesz ponowne użycie urządzeń z wieloma pacjentami, zaleca się utworzenie zasobu urządzenia wirtualnego specyficznego dla pacjenta i wysłanie identyfikatora urządzenia wirtualnego w ładunku komunikatu urządzenia. Urządzenie wirtualne może być połączone z rzeczywistym zasobem urządzenia jako elementem nadrzędnym.

Jeśli w usłudze FHIR nie istnieje żaden zasób urządzenia dla danego identyfikatora urządzenia, wynik zależy od wartości typu rozwiązania ustawionego w momencie wdrożenia usługi MedTech. Po ustawieniu opcji Lookup określony komunikat jest ignorowany, a potok nadal przetwarza inne przychodzące komunikaty urządzenia. W przypadku ustawienia opcji Utwórz usługa MedTech tworzy minimalne zasoby urządzenia i pacjenta w usłudze FHIR.

Uwaga

Typ rozwiązania można również dostosować po wdrożeniu usługi MedTech, jeśli wymagany jest inny typ rozwiązania.

Usługa MedTech zapewnia przetwarzanie niemal w czasie rzeczywistym, a także próbuje zmniejszyć liczbę żądań wysyłanych do usługi FHIR, grupując żądania w partie 300 znormalizowanych komunikatów. Jeśli istnieje mała ilość danych, a 300 znormalizowanych komunikatów nie zostało dodanych do grupy, odpowiednie obserwacje FHIR w tej grupie są utrwalane w usłudze FHIR po około pięciu minutach.

Uwaga

Jeśli wiele komunikatów urządzenia zawiera dane dla tej samej obserwacji FHIR, mają ten sam znacznik czasu i są wysyłane w tej samej partii komunikatów urządzenia (na przykład w ciągu pięciu minut lub w grupach 300 znormalizowanych komunikatów), tylko dane odpowiadające najnowszemu komunikatowi urządzenia dla tej obserwacji FHIR są utrwalane.

Przykład:

Komunikat urządzenia 1:

{    
   "patientid": "testpatient1",    
   "deviceid": "testdevice1",
   "systolic": "129",    
   "diastolic": "65",    
   "measurementdatetime": "2022-02-15T04:00:00.000Z"
}

Komunikat urządzenia 2:

{   
   "patientid": "testpatient1",    
   "deviceid": "testdevice1",    
   "systolic": "113",    
   "diastolic": "58",    
   "measurementdatetime": "2022-02-15T04:00:00.000Z"
}

Przy założeniu, że te komunikaty urządzenia zostały pozyskane w tym samym pięciominutowym oknie lub w tej samej grupie 300 znormalizowanych komunikatów, a ponieważ measurementdatetime wartość jest taka sama dla obu komunikatów urządzenia (wskazujących, że zawierają one dane dla tej samej obserwacji FHIR), tylko komunikat urządzenia 2 jest utrwalany w celu reprezentowania najnowszych/najnowszych danych.

Persist

Trwałość to ostatni etap, w którym obserwacje FHIR z etapu transformacji są utrwalane w usłudze FHIR. Jeśli obserwacja FHIR jest nowa, zostanie utworzona w usłudze FHIR. Jeśli obserwacja FHIR już istniała, zostanie zaktualizowana w usłudze FHIR. Usługa FHIR używa przypisanej przez system tożsamości zarządzanej usługi MedTech i kontroli dostępu opartej na zasobach (Azure RBAC) na potrzeby bezpiecznego dostępu do usługi FHIR.