ניהול מאגר נתונים של חיפושים בתחום הבריאות

הוצאה משימוש: התכונה 'חיפוש מבוסס סוכנים' בתחום שירותי הבריאות הוצאה משימוש ולא תהיה זמינה אחרי 15 במאי 2027.

אחרי שיוצרים מאגרי נתונים של נתונים בתחום הבריאות ומייבאים נתוני FHIR R4, אפשר לבצע את הפעולות הבאות כדי לנהל אותם:

• ביטול ייבוא של קבוצת משתמשים
• השהיה או המשך של הסטרימינג.
• סנכרון ידני של נתונים שמוזרמים:
  • סנכרון כל המסמכים.
  • סנכרון סלקטיבי של מסמכים.
  • סנכרון מסמכים אחרי חותמת זמן מסוימת.
• מחיקת סטרימינג.

ביטול ייבוא של קבוצת פריטים

כדי לבטל פעולת ייבוא אצווה מתמשכת:

REST

1. מאתרים את מזהה הפעולה של פעולת הייבוא ב-Batch. מזהה הפעולה הזה זהה לזה שמוחזר כשמייבאים את הנתונים למאגר הנתונים. אם כבר יש לכם מזהה פעולה, דלגו לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על מאגר הנתונים שרוצים לבטל את הייבוא שלו.

   3. בדף הפרטים של מאגר הנתונים, לוחצים על הצגת הפרטים. האפשרות הזו זמינה רק אחרי שיוצרים את פעולת הייבוא והיא מתבצעת.

   4. בחלונית פרטים של יומן הפעילות, מעתיקים את מזהה הפעולה.

2. ביטול ייבוא מתמשך של מקבץ.

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/default_collection/dataStores/DATA_STORE_ID/branches/0/operations/OPERATION_ID:cancel" \
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫DATA_STORE_ID: המזהה של מאגר הנתונים שרוצים לבטל את הייבוא המתמשך של מנות נתונים.
   • ‫IMPORT_OPERATION_ID: המזהה של פעולת הייבוא באצווה שמתבצעת כרגע ורוצים לבטל.

   אם הפעולה בוטלה בהצלחה, אמור להתקבל אובייקט JSON ריק.

השהיה או המשך של סטרימינג

כדי להשהות או להמשיך פעולת סטרימינג:

המסוף

1. נכנסים לדף AI Applications במסוף Google Cloud .

   אפליקציות AI

2. בתפריט הניווט, לוחצים על מאגרי נתונים.

   בדף מאגרי נתונים מוצגת רשימה של מאגרי נתונים בפרויקט Google Cloudעם הפרטים שלהם.

3. לוחצים על מאגר הנתונים שרוצים להשהות או להמשיך את הסטרימינג שלו.

4. בדף נתונים של מחבר הנתונים, לוחצים על השהיית הזרמת הנתונים כדי להשהות את ההזרמה או על חידוש הזרמת הנתונים כדי לחדש את הזרמת הנתונים.

REST

1. מאתרים את מזהה האוסף. אם כבר יש לכם מזהה אוסף, אפשר לדלג לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על השם של מחבר הנתונים שרוצים להשהות או להפעיל מחדש את הסטרימינג שלו.

   3. בדף נתונים של מחבר הנתונים, מעתיקים את מזהה האוסף.

2. השהיה או המשך של הסטרימינג בתוך מחבר נתונים.

   curl -X PATCH \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector?updateMask=auto_run_disabled" \
   -d ' {
     "name":"projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector",
     "autoRunDisabled": PAUSE_STREAM_TRUE|FALSE
   }'
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫COLLECTION_ID: המזהה של מחבר הנתונים שרוצים להשהות או לחדש את הסטרימינג שלו.
   • ‫PAUSE_STREAM_TRUE|FALSE: ערך בוליאני. אם הערך הוא true, השידור מושהה. אם הערך הוא false, השידור שמושהה ממשיך.

   תשובה

   אתם אמורים לקבל תגובת JSON שדומה לזו: השדה autoRunDisabled מוחזר רק כשמשהים את הזרמת הנתונים.

   {
     "name": "projects/PROJECT_NUMBER/locations/us/collections/COLLECTION_ID/dataConnector",
     "state": "ACTIVE",
     "dataSource": "gcp_fhir",
     "params": {
       "instance_uri": "projects/PROJECT_ID/locations/us-central1/datasets/synthea-mock"
     },
     "refreshInterval": "0s",
     "entities": [
       {
         "entityName": "DATA_STORE_NAME",
         "dataStore": "projects/PROJECT_NUMBER/locations/us/collections/default_collection/dataStores/DATA_STORE_ID"
       }
     ],
     "createTime": "DATA_STORE_CREATE_TIMESTAMP",
     "syncMode": "STREAMING",
     "autoRunDisabled": true,
     "actionConfig": {},
     "latestPauseTime": "PAUSE_TIMESTAMP",
     "lastSyncTime": "LAST_SYNC_TIMESTAMP",
     "updateTime": "UPDATE_TIMESTAMP",
     "identityScheduleConfig": {}
   }
   

סנכרון של כל המסמכים במאגר נתונים של סטרימינג

אתם יכולים להפעיל מילוי חוסרים באופן ידני לכל המסמכים עם סוגי המשאבים הנתמכים של FHIR. כך תוכלו לעדכן את מאגר הנתונים של חיפוש מבוסס סוכנים בהתאם למאגר ה-FHIR של Cloud Healthcare API. אפשר לסנכרן נתונים רק במאגרי נתונים של סטרימינג.

כדי לסנכרן את כל המסמכים במאגר נתונים של נתונים בזמן אמת:

המסוף

1. נכנסים לדף AI Applications במסוף Google Cloud .

   אפליקציות AI

2. בתפריט הניווט, לוחצים על מאגרי נתונים.

   בדף מאגרי נתונים מוצגת רשימה של מאגרי נתונים בפרויקט Google Cloudעם הפרטים שלהם.

3. בוחרים את הנתונים של מחבר הנתונים שרוצים לסנכרן.

4. בדף הפרטים של מאגר הנתונים, לוחצים על ייבוא מחדש.

5. בחלונית ייבוא מחדש של נתונים, לוחצים על , בוחרים תאריך שאחריו רוצים לסנכרן את הנתונים ולוחצים על סגירה.

6. בקטע Resources to re-import (משאבים לייבוא מחדש), בוחרים את כל סוגי משאבי ה-FHIR. כך יתבצע מילוי חוזר של כל המסמכים עם סוגי משאבי FHIR הנתמכים.

7. לוחצים על ייבוא מחדש.

REST

1. מאתרים את מזהה האוסף. אם כבר יש לכם מזהה אוסף, אפשר לדלג לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על השם של מחבר הנתונים שרוצים להשהות או להפעיל מחדש את הסטרימינג שלו.

   3. בדף נתונים של מחבר הנתונים, מעתיקים את מזהה האוסף.

2. הפעלת סנכרון או מילוי חוזר של כל המסמכים עם סוגי משאבים נתמכים של FHIR.

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
   -d ' {
     "syncSinceTimestamp": {}
   }'
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫COLLECTION_ID: המזהה של האוסף שרוצים להשהות או לחדש את הסטרימינג שלו.

   תשובה

   אתם אמורים לקבל תגובת JSON שדומה לזו: התשובה מכילה מזהה של הפעלת מחבר. בשדה state מוצג אחד מהסטטוסים של הרצת הסנכרון. מידע נוסף זמין במאמר בנושא ConnectorRun.

   {
     "name": "projects/189082903055/locations/us/collections/contact/dataConnector/connectorRuns/CONNECTOR_RUN_ID",
     "state": "CONNECTOR_RUN_STATE"
   }
   

   אם קוראים שוב לשיטה startConnectorRun בזמן שהיא עדיין פועלת, יכול להיות שתקבלו שגיאה.

סנכרון של מסמכים נבחרים במאגר נתונים של סטרימינג

אפשר לייבא מסמכים נבחרים עם סוגי משאבי FHIR הנתמכים. האפשרות הזו שימושית כשרוצים לעדכן את מאגר הנתונים של חיפוש מבוסס סוכנים במסמכים מסוגים מסוימים של משאבי FHIR. אפשר לסנכרן נתונים רק במאגרי נתונים של עיבוד סטרימינג.

כדי לסנכרן מסמכים נבחרים במאגר נתונים של סטרימינג, מבצעים את הפעולות הבאות:

המסוף

1. נכנסים לדף AI Applications במסוף Google Cloud .

   אפליקציות AI

2. בתפריט הניווט, לוחצים על מאגרי נתונים.

   בדף מאגרי נתונים מוצגת רשימה של מאגרי נתונים בפרויקט Google Cloudעם הפרטים שלהם.

3. בוחרים את הנתונים של מחבר הנתונים שרוצים לסנכרן.

4. בדף הפרטים של מאגר הנתונים, לוחצים על ייבוא מחדש.

5. בחלונית ייבוא מחדש של נתונים, לוחצים על , בוחרים תאריך שאחריו רוצים לסנכרן את הנתונים ולוחצים על סגירה.

6. בקטע Resources to re-import (משאבים לייבוא מחדש), בוחרים את כל סוגי משאבי ה-FHIR שרוצים לייבא. פעולה כזו מייבאת את כל המסמכים מסוגי משאבי ה-FHIR שנבחרו.

7. לוחצים על ייבוא מחדש.

REST

1. מאתרים את מזהה האוסף. אם כבר יש לכם מזהה אוסף, אפשר לדלג לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על השם של מחבר הנתונים שרוצים להשהות או להפעיל מחדש את הסטרימינג שלו.

   3. בדף נתונים של מחבר הנתונים, מעתיקים את מזהה האוסף.

2. הפעלת סנכרון או מילוי חוסרים של מסמכים נבחרים עם סוגי משאבים נתמכים של FHIR.

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
   -d ' {
     "syncSinceTimestamp": {},
     "healthcareFhirResourceTypes": "Patient",
     "healthcareFhirResourceTypes": "RESOURCE_TYPE"
   }'
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫COLLECTION_ID: המזהה של האוסף שרוצים להשהות או לחדש את הסטרימינג שלו.
   • ‫RESOURCE_TYPE: סוג המשאב של מסמכי FHIR שרוצים למלא מחדש.

   תשובה

   אתם אמורים לקבל תגובת JSON שדומה לזו: התשובה מכילה מזהה של הפעלת מחבר. בשדה state מוצג אחד מהסטטוסים של תהליך הסנכרון. מידע נוסף זמין במאמר בנושא ConnectorRun.

   {
     "name": "projects/189082903055/locations/us/collections/contact/dataConnector/connectorRuns/CONNECTOR_RUN_ID",
     "state": "CONNECTOR_RUN_STATE"
   }
   

   אם קוראים שוב לשיטה startConnectorRun בזמן שהיא עדיין פועלת, יכול להיות שתקבלו שגיאה.

סנכרון מסמכים אחרי חותמת זמן נתונה במאגר נתונים של נתונים זורמים

אפשר לייבא מסמכים נבחרים עם סוגי המשאבים הנתמכים ב-FHIR אחרי חותמת זמן מסוימת. אפשר לסנכרן נתונים רק במאגרי נתונים של עיבוד סטרימינג.

כדי לסנכרן מסמכים אחרי חותמת זמן מסוימת:

המסוף

1. נכנסים לדף AI Applications במסוף Google Cloud .

   אפליקציות AI

2. בתפריט הניווט, לוחצים על מאגרי נתונים.

   בדף מאגרי נתונים מוצגת רשימה של מאגרי נתונים בפרויקט Google Cloudעם הפרטים שלהם.

3. בוחרים את הנתונים של מחבר הנתונים שרוצים לסנכרן.

4. בדף הפרטים של מאגר הנתונים, לוחצים על ייבוא מחדש.

5. בחלונית ייבוא מחדש של נתונים, לוחצים על , בוחרים תאריך שאחריו רוצים לסנכרן את הנתונים ולוחצים על סגירה.

6. בקטע Resources to re-import (משאבים לייבוא מחדש), בוחרים את כל סוגי משאבי ה-FHIR שרוצים לייבא. פעולה כזו מייבאת את כל המסמכים מסוגי משאבי ה-FHIR שנבחרו.

7. לוחצים על ייבוא מחדש.

REST

1. מאתרים את מזהה האוסף. אם כבר יש לכם מזהה אוסף, אפשר לדלג לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על השם של מחבר הנתונים שרוצים להשהות או להפעיל מחדש את הסטרימינג שלו.

   3. בדף נתונים של מחבר הנתונים, מעתיקים את מזהה האוסף.

2. הפעלת סנכרון או מילוי חוזר של כל המסמכים עם סוגי משאבים נתמכים של FHIR.

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
   -d ' {
     "syncSinceTimestamp": {
       "seconds": TIMESTAMP_SECONDS,
       "nanos": TIMESTAMP_NANOS
     }
   }'
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫COLLECTION_ID: המזהה של האוסף שרוצים להשהות או לחדש את הסטרימינג שלו.
   • ‫TIMESTAMP_SECONDS: הערך של חותמת הזמן בשניות מאז הזמן שבו רוצים לייבא את המסמכים. הפורמט הוא חותמת זמן.
   • ‫TIMESTAMP_NANOS: הערך של חותמת הזמן בשניות מאז הזמן שבו רוצים לייבא את המסמכים. הפורמט הוא חותמת זמן.

   תשובה

   אתם אמורים לקבל תגובת JSON שדומה לזו: התשובה מכילה מזהה של הפעלת מחבר. בשדה state מוצג אחד מהסטטוסים של תהליך הסנכרון. מידע נוסף זמין במאמר בנושא ConnectorRun.

   {
     "name": "projects/189082903055/locations/us/collections/contact/dataConnector/connectorRuns/CONNECTOR_RUN_ID",
     "state": "CONNECTOR_RUN_STATE"
   }
   

   אם קוראים שוב לשיטה startConnectorRun בזמן שהיא עדיין פועלת, יכול להיות שתקבלו שגיאה.

מחיקת סטרימינג

כדי למחוק פעולת סטרימינג:

המסוף

1. נכנסים לדף AI Applications במסוף Google Cloud .

   אפליקציות AI

2. בתפריט הניווט, לוחצים על מאגרי נתונים.

   בדף מאגרי נתונים מוצגת רשימה של מאגרי נתונים בפרויקט Google Cloudעם הפרטים שלהם.

3. ברשימת מאגרי הנתונים, לוחצים על אפשרויות נוספות עבור מחבר הנתונים שרוצים למחוק.

4. לוחצים על מחיקה.

5. בתיבת הדו-שיח שמופיעה, מקלידים yes ולוחצים על Confirm כדי לאשר את המחיקה.

REST

1. מאתרים את מזהה האוסף. אם כבר יש לכם מזהה אוסף, אפשר לדלג לשלב הבא.

   1. במסוף Google Cloud , עוברים לדף AI Applications ובתפריט הניווט לוחצים על Data Stores.

      מעבר לדף Data Stores

   2. לוחצים על השם של מחבר הנתונים שרוצים להשהות או להפעיל מחדש את הסטרימינג שלו.

   3. בדף נתונים של מחבר הנתונים, מעתיקים את מזהה האוסף.

2. הפעלת סנכרון או מילוי חוזר של כל המסמכים עם סוגי משאבים נתמכים של FHIR.

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
   -d ' {
     "syncSinceTimestamp": {
       "seconds": TIMESTAMP_SECONDS,
       "nanos": TIMESTAMP_NANOS
     }
   }'
   

   מחליפים את מה שכתוב בשדות הבאים:

   • ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
   • ‫COLLECTION_ID: המזהה של האוסף שרוצים להשהות או לחדש את הסטרימינג שלו.
   • ‫TIMESTAMP_SECONDS: הערך של חותמת הזמן בשניות מאז הזמן שבו רוצים לייבא את המסמכים. הפורמט הוא חותמת זמן.
   • ‫TIMESTAMP_NANOS: הערך של חותמת הזמן בשניות מאז הזמן שבו רוצים לייבא את המסמכים. הפורמט הוא חותמת זמן.

   תשובה

   אתם אמורים לקבל תגובת JSON שדומה לזו: התשובה מכילה מזהה של הפעלת מחבר. בשדה state מוצג אחד מהסטטוסים של תהליך הסנכרון. מידע נוסף זמין במאמר בנושא ConnectorRun.

   {
     "name": "projects/189082903055/locations/us/collections/contact/dataConnector/connectorRuns/CONNECTOR_RUN_ID",
     "state": "CONNECTOR_RUN_STATE"
   }
   

   אם קוראים שוב לשיטה startConnectorRun בזמן שהיא עדיין פועלת, יכול להיות שתקבלו שגיאה.