הכנסה לקליק

מחלקה סופית ציבורית Rpc

בצע קבוצות של בקשות RPC.

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

- `כתובת` (המארח+פורט או כתובת ה-BNS של הבקשה) - `שיטה` (שם שיטת RPC לבקשה) - `request` (מחרוזת הפרוטו המסודרת, או וקטור המחרוזות, של הארגומנט של בקשת RPC) .

לדוגמה, אם יש לך שירות RPC שפועל על port localhost:2345, והממשק שלו מוגדר עם הצהרת הפרוטו הבאה:

service MyService {
   rpc MyMethod(MyRequestProto) returns (MyResponseProto) {
   
 };
 }
אז קרא ל-op זה עם ארגומנטים:
address = "localhost:2345"
 method = "MyService/MyMethod"
 
טנסור ה-'request' הוא טנסור מחרוזת המייצג מחרוזות 'MyRequestProto' בסידרה; ולמחרוזת הפלט 'תגובה' תהיה אותה צורה והיא תכיל (עם השלמתה מוצלחת) מחרוזות 'MyResponseProto' תואמות.

לדוגמה, כדי לשלוח יחיד, ריק, `MyRequestProto`, קרא למבצע הזה עם `request = ""`. כדי לשלוח 5 בקשות ריקות מקבילות , התקשר לפעולה זו עם `request = ["", "", "", "", ""]`.

באופן כללי יותר, אפשר ליצור אצווה של 'MyRequestProto' פרוטו סדרתי מטנזורים אצווה רגילים באמצעות האופציה של 'encode_proto', ולהמיר את התגובה 'MyResponseProto' פרוטו סידורי לטנזורים אצווה באמצעות האופ של 'decode_proto'.

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

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

ראה את האופציה של 'TryRpc' אם אתה מעדיף לטפל בתקלות RPC באופן ידני בגרף.

כיתות מקוננות

מעמד Rpc.Options תכונות אופציונליות עבור Rpc

שיטות ציבוריות

פלט <מחרוזת>
asOutput ()
מחזירה את הידית הסמלית של טנזור.
Rpc סטטי
צור ( היקף היקף , כתובת <מחרוזת> של Operand , שיטת <מחרוזת> של Operand , בקשת Operand <מחרוזת>, אפשרויות... אפשרויות)
שיטת מפעל ליצירת מחלקה העוטפת פעולת Rpc חדשה.
סטטי Rpc.Options
failFast (failFast בוליאני)
סטטי Rpc.Options
פרוטוקול (פרוטוקול מחרוזת)
פלט <מחרוזת>
תגובה ()
אותה צורה כמו 'בקשה'.
סטטי Rpc.Options
timeoutInMs (Long timeoutInMs)

שיטות בירושה

שיטות ציבוריות

פלט ציבורי <String> asOutput ()

מחזירה את הידית הסמלית של טנזור.

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

יצירת Rpc סטטי ציבורי (היקף היקף , כתובת <מחרוזת> של Operand , שיטת <מחרוזת> של Operand , בקשת Operand <String>, אפשרויות... אפשרויות)

שיטת מפעל ליצירת מחלקה העוטפת פעולת Rpc חדשה.

פרמטרים
תְחוּם ההיקף הנוכחי
כתובת `0-D` או `1-D`. הכתובת (כלומר host_name:port) של שרת ה-RPC. אם לטנזור זה יש יותר מאלמנט אחד, נשלחות מספר בקשות rpc מקבילות. טיעון זה משדר עם `שיטה` ו`בקשה`.
שיטה `0-D` או `1-D`. כתובת השיטה בשרת RPC. אם לטנזור זה יש יותר מאלמנט אחד, נשלחות מספר בקשות rpc מקבילות. ארגומנט זה משדר עם 'כתובת' ו'בקשה'.
בַּקָשָׁה `0-D` או `1-D`. מחרוזות פרוטו מסודרות: ארגומנט בקשת rpc. אם לטנזור זה יש יותר מאלמנט אחד, נשלחות מספר בקשות rpc מקבילות. טיעון זה משדר עם `כתובת` ו`שיטה`.
אפשרויות נושא ערכי תכונות אופציונליות
החזרות
  • מופע חדש של Rpc

public static Rpc.Options failFast (בוליאני failFast)

פרמטרים
failFast 'בוליאני'. אם 'true' (ברירת מחדל), אזי כשלים בחיבור (כלומר, השרת לא מגיב מיד) גורמים לכשל RPC.

פרוטוקול Rpc.Options סטטי ציבורי (פרוטוקול מחרוזת)

פרמטרים
נוהל פרוטוקול RPC לשימוש. מחרוזת ריקה פירושה שימוש בפרוטוקול ברירת המחדל. האפשרויות כוללות 'grpc'.

תגובת <String> פלט ציבורית ()

אותה צורה כמו 'בקשה'. מחרוזות פרוטו מסודרות: תגובות ה-rpc.

public static Rpc.Options timeoutInMs (Long timeoutInMs)

פרמטרים
timeoutInMs `int`. אם '0' (ברירת מחדל), אזי הקרנל יריץ את בקשת ה-RPC ופסק זמן רק אם תאריך היעד של ה-RPC יעבור או שהסשן יעבור זמן קצוב. אם ערך זה גדול מ-'0', אזי הפעולה תעלה חריגה אם ה-RPC לוקח יותר מ-'timeout_in_ms'.