פרסום אירוע ב-Cloud Pub/Sub באמצעות ABAP SDK ל-Google Cloud
מידע על Codelab זה
subjectהעדכון האחרון: ספט׳ 4, 2024
1. מבוא
בקודלאב הזה פירטנו את השלבים לפרסום אירוע ב-Google Cloud Pub/Sub API באמצעות ABAP SDK for Google Cloud.
בקודלאב הזה נעשה שימוש בשירותי Google Cloud הבאים:
- Pub/Sub
- Cloud Shell
מה תפַתחו
במדריך הזה תלמדו:
- מפעילים את Pub/Sub בפרויקט ב-Google Cloud.
- יוצרים נושא Pub/Sub.
- לפרסם הודעות.
2. לפני שמתחילים
- התקנתם את ABAP SDK for Google Cloud במערכת. אפשר להיעזר בקודלאב התקנת ABAP Trial ב-Google Cloud Platform כדי להגדיר מערכת חדשה.
- משתמשים ב-Cloud Shell, סביבת שורת פקודה שפועלת ב-Google Cloud. במסוף Cloud, לוחצים על Activate Cloud Shell בפינה הימנית העליונה:
- מריצים את הפקודות הבאות כדי לבצע אימות לחשבון ולהגדיר את פרויקט ברירת המחדל כ-
abap-sdk-poc. הדוגמה היא לתחוםus-west4-b. אם צריך, משנים את הפרויקט ואת האזור בפקודות הבאות בהתאם להעדפות שלכם.
gcloud auth login
gcloud config set project abap-sdk-poc
gcloud config set compute/zone us-west4-b
3. סקירה כללית
היקף הקודלאב הזה כולל את הרכיבים הבאים של שירות Pub/Sub:
- בעל אפליקציה (נקרא גם 'בעל תוכן דיגיטלי'): יוצר הודעות ושולח (מפרסם) אותן לשירות העברת ההודעות בנושא מסוים.
- הודעה: הנתונים שעוברים דרך שירות ההודעות.
- נושא: ישות בעלת שם שמייצגת פיד של הודעות.
4. הגדרת שירות Pub/Sub
- כדי ליצור חשבון שירות עם התפקיד הנדרש, מריצים את הפקודה הבאה במסוף של Cloud Shell:
gcloud iam service-accounts create abap-sdk-pubsub-tester --display-name="Service Account for PubSub"
- כדי להפעיל את Pub/Sub API בחשבון השירות (
abap-sdk-poc), מריצים את הפקודה הבאה במסוף של Cloud Shell:
gcloud services enable pubsub.googleapis.com
- מקצים לחשבון השירות את תפקיד ה-IAM pubsub.topics.create כדי שיהיה אפשר ליצור נושא. מריצים את הפקודה הבאה במסוף של Cloud Shell:
gcloud endpoints services add-iam-policy-binding pubsub.googleapis.com \ --member='serviceAccount:abap-sdk-pubusb-tester@abap-sdk-poc.iam.gserviceaccount.com' \
--role='roles/roles/pubsub.topics.create'
- מקצים לחשבון השירות את תפקיד ה-IAM pubsub.topics.publish כדי שיהיה אפשר לפרסם הודעה בנושא. מריצים את הפקודה הבאה במסוף של Cloud Shell:
gcloud endpoints services add-iam-policy-binding pubsub.googleapis.com \ --member='serviceAccount:abap-sdk-pubusb-tester@abap-sdk-poc.iam.gserviceaccount.com' \
--role='roles/roles/pubsub.topics.publish'
- כדי לוודא שהתפקידים נוספו, עוברים לדף IAM. חשבון השירות שיצרתם אמור להופיע ברשימה יחד עם התפקידים שהוקצו לו.
5. הגדרת מפתח לקוח
כדי לשמור על ההגדרות בטבלה /GOOG/CLIENT_KEY:
- בממשק המשתמש של SAP, מזינים את קוד העסקה SPRO.
- לוחצים על SAP Reference IMG.
- לוחצים על ABAP SDK for Google Cloud > Basic Settings > Configure Client Key.
- לוחצים על New Entries.
- מזינים ערכים בשדות הבאים:
שדה | תיאור |
שם המפתח ב-Google Cloud | PUBSUB_DEMO |
שם חשבון השירות ב-Google Cloud | abap-sdk-dev@abap-sdk-poc.iam.gserviceaccount.com |
היקף Google Cloud | https://www.googleapis.com/auth/cloud-platform |
מזהה הפרויקט ב-Google Cloud | abap-sdk-poc |
Authorization Class | /GOOG/CL_AUTH_GOOGLE |
משאירים את שאר השדות ריקים
6. יצירת נושא
יוצרים נושא באמצעות השיטה CREATE_TOPICS של ה-stub של ה-API /GOOG/CL_PUBSUB_V1. החתימה של השיטה:
- בממשק המשתמש של SAP, מזינים את קוד העסקה SE38.
- יוצרים דוח בשם ZPUBSUB_DEMO.
- בחלון הקופץ שנפתח, מזינים את הפרטים כפי שמתואר בהמשך ולוחצים על שמירה.
- בחלון הקופץ הבא, בוחרים באפשרות Local Object (אובייקט מקומי) או מספקים שם לחבילה בהתאם.
- בעורך ABAP, מוסיפים את הקוד הבא:
" Data Declaration
DATA:
lo_client TYPE REF TO /goog/cl_pubsub_v1.
TRY.
" Open HTTP Connection
CREATE OBJECT lo_client EXPORTING iv_key_name = 'PUBSUB_DEMO'.
" Populate relevant parameters
DATA(lv_p_projects_id) = CONV string( lo_client->gv_project_id ).
DATA(lv_p_topics_id) = CONV string( 'PUBSUB_DEMO_TOPIC' ).
" Call API method pubsub.topics.create
lo_client->create_topics(
EXPORTING
iv_p_projects_id = lv_p_projects_id
iv_p_topics_id = lv_p_topics_id
IMPORTING
es_output = DATA(ls_output)
ev_ret_code = DATA(lv_ret_code)
ev_err_text = DATA(lv_err_text)
es_err_resp = DATA(ls_err_resp) ).
IF lo_client->is_success( lv_ret_code ) = abap_true.
DATA(lv_msg) = 'Topic ' && ':' && lv_p_topics_id && ' was created!'.
MESSAGE lv_msg TYPE 'I' .
ELSE.
MESSAGE lv_err_text TYPE 'E'.
ENDIF.
" Close HTTP Connection
lo_client->close( ).
CATCH /goog/cx_sdk INTO DATA(lo_exception).
MESSAGE lo_exception->get_text( ) TYPE 'E'.
RETURN.
ENDTRY.
- שומרים ומפעילים את הדוח.
- מפעילים את הדוח (F8).
אם הפקודה תתבצע בהצלחה, הפלט של הדוח אמור להיראות כך:
7. פרסום הודעה בנושא
עכשיו, כשהנושא מוכן, נוכל להתמקד בשליחת הנתונים. בשלב הבא נסביר איך מפרסמים הודעות בנושא הזה. ההודעות מתפרסמות בנושא באמצעות השיטה PUBLISH_TOPICS של סטאב ה-API /GOOG/CL_PUBSUB_V1.
החתימה של השיטה:
- בממשק המשתמש של SAP, מזינים את קוד העסקה SE38.
- יוצרים דוח בשם ZPUBSUB_DEMO_PUBLISH.
- בחלון הקופץ שנפתח, מזינים את הפרטים כפי שמתואר בהמשך ולוחצים על שמירה.
- בחלון הקופץ הבא, בוחרים באפשרות Local Object (אובייקט מקומי) או מספקים שם לחבילה בהתאם.
- בעורך ABAP, מוסיפים את הקוד הבא:
" Data Declaration
DATA:
lo_client TYPE REF TO /goog/cl_pubsub_v1,
ls_message TYPE /goog/cl_pubsub_v1=>ty_025,
ls_input TYPE /goog/cl_pubsub_v1=>ty_023.
TRY.
" Open HTTP Connection
CREATE OBJECT lo_client EXPORTING iv_key_name = 'PUBSUB_DEMO'.
" Populate relevant parameters
DATA(lv_p_projects_id) = CONV string( lo_client->gv_project_id ).
DATA(lv_p_topics_id) = CONV string( 'PUBSUB_DEMO_TOPIC' ).
ls_message-data = cl_http_utility=>encode_base64( unencoded = ' This message was published to topic' ).
APPEND ls_message TO ls_input-messages.
" Call API method : pubsub.topics.publish
" This method publishes the message(encoded in base64 format to the topic )
lo_client->publish_topics(
EXPORTING
iv_p_projects_id = lv_p_projects_id
iv_p_topics_id = lv_p_topics_id
is_input = ls_input
IMPORTING
es_output = DATA(ls_output)
ev_ret_code = DATA(lv_ret_code)
ev_err_text = DATA(lv_err_text)
es_err_resp = DATA(ls_err_resp) ).
IF lo_client->is_success( lv_ret_code ) = abap_true.
DATA(lv_msg) = 'Message was published to topic ' && ': ' && lv_p_topics_id.
MESSAGE lv_msg TYPE 'I' DISPLAY LIKE 'S'.
ELSE.
MESSAGE lv_err_text TYPE 'E'.
ENDIF.
" Close HTTP Connection
lo_client->close( ).
CATCH /goog/cx_sdk INTO DATA(lo_exception).
MESSAGE lv_err_text TYPE 'E'.
RETURN.
ENDTRY.
- שומרים ומפעילים את הדוח.
- מפעילים את הדוח (F8).
אם הפקודה תתבצע בהצלחה, הפלט של הדוח אמור להיראות כך:
8. מזל טוב
מעולה! פרסמתם בהצלחה הודעה ב-Pub/Sub API של Google Cloud Platform באמצעות ABAP SDK ל-Google Cloud.
עכשיו אפשר להמשיך ב-codelab הבא כדי להמשיך את תהליך הלמידה של השימוש ב-ABAP SDK כדי לגשת לשירותים שונים של Google Cloud.
- קבלת אירוע מ-Cloud Pub/Sub
- העלאת קובץ לקטגוריה של Cloud Storage באמצעות חלוקה למקטעים
- קריאה ל-Vertex AI test-bison מ-ABAP
- . . .
9. הסרת המשאבים
אם אתם לא רוצים להמשיך בקודלאבים הנוספים שקשורים ל-ABAP SDK ל-Google Cloud, תוכלו להמשיך לניקוי.
מחיקת הפרויקט
- מוחקים את הפרויקט ב-Google Cloud:
gcloud projects delete abap-sdk-poc
מחיקת משאבים ספציפיים
- מוחקים את מכונה לעיבוד נתונים:
gcloud compute instances delete abap-trial-docker
- מוחקים את כללי חומת האש:
gcloud compute firewall-rules delete sapmachine
- מוחקים את חשבון השירות:
gcloud iam service-accounts delete \
abap-sdk-dev@abap-sdk-poc.iam.gserviceaccount.com