Google Cloud Pub/Sub에 메시지 게시

이 빠른 시작에서는 ABAP SDK for Google Cloud의 SAP BTP 버전에서 Pub/Sub API를 사용하여 'Hello World!' 메시지를 게시하는 프로그램을 생성하는 방법을 보여줍니다.

시작하기 전에

이 빠른 시작을 실행하기 전에 직접 또는 관리자가 다음 기본 요건을 완료했는지 확인합니다.

  • 서비스 계정에 IAM 역할 roles/pubsub.publisher를 부여합니다.

  • Google Cloud 프로젝트에서 Pub/Sub API가 사용 설정되어 있는지 확인합니다.

    API 라이브러리로 이동

  • Pub/Sub 주제 SAMPLE_TOPIC_01을 만들고 풀 구독 SAMPLE_SUB_TOPIC_01을 동일한 주제에 추가합니다. 자세한 내용은 주제 만들기 및 구독 만들기를 참조하세요.

Pub/Sub 주제에 메시지를 게시하기 위한 ABAP 클래스 만들기

  1. 패키지를 만듭니다.

    1. ADT에서 프로젝트 탐색기로 이동합니다.
    2. ZLOCAL 패키지를 마우스 오른쪽 버튼으로 클릭하고 새로 만들기 > ABAP 패키지를 선택합니다.

    3. 패키지에 대한 다음 세부정보를 입력합니다.

      • 이름: ZABAPSDK_TEST를 입력합니다.
      • 설명: ABAP SDK Test Package를 입력합니다.

    4. 다음을 클릭합니다.

    5. 전송 요청 선택 대화상자에서 새 요청 만들기 체크박스를 선택합니다.

    6. 전송 요청에 대한 설명을 입력합니다.

    7. 마침을 클릭합니다.

  2. Pub/Sub API를 호출하는 ABAP 클래스를 만듭니다.

    1. ABAP 패키지를 마우스 오른쪽 버튼으로 클릭하고 새로 만들기 > ABAP 클래스를 선택합니다.

    2. ABAP 클래스에 대해 다음 세부정보를 입력합니다.

      • 이름: ZGOOG_CL_QS_PUBSUB를 입력합니다.
      • 설명: Quick start for Pub/Sub API를 입력합니다.

    3. 다음을 클릭합니다.

    4. 전송 요청을 선택하고 마침을 클릭합니다.

  3. 코드 편집기에서 기본 코드를 다음 코드 스니펫으로 바꿉니다.

    " --------------------------------------------------------------------
"  Copyright 2024 Google LLC                                         -
"                                                                    -
"  Licensed under the Apache License, Version 2.0 (the "License");   -
"  you may not use this file except in compliance with the License.  -
"  You may obtain a copy of the License at                           -
"      https://www.apache.org/licenses/LICENSE-2.0                   -
"  Unless required by applicable law or agreed to in writing,        -
"  software distributed under the License is distributed on an       -
"  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,      -
"  either express or implied.                                        -
"  See the License for the specific language governing permissions   -
"  and limitations under the License.                                -
" --------------------------------------------------------------------
CLASS zcl_qs_publish_messages DEFINITION
  PUBLIC FINAL
  CREATE PUBLIC.

  PUBLIC SECTION.
    INTERFACES if_oo_adt_classrun.
ENDCLASS.



CLASS ZCL_QS_PUBLISH_MESSAGES IMPLEMENTATION.


  METHOD if_oo_adt_classrun~main.

    DATA ls_input         TYPE /goog/cl_pubsub_v1=>ty_023.
    DATA lo_pubsub        TYPE REF TO /goog/cl_pubsub_v1.
    DATA lv_p_projects_id TYPE string.
    DATA lv_p_topics_id   TYPE string.

    TRY.
        " Open HTTP connection
        " The client key DEMO_PUBSUB is an example, replace this with actual value
        lo_pubsub = NEW /goog/cl_pubsub_v1( iv_key_name = 'DEMO_PUBSUB' ).

        " Pass the relevant input parameters
        " The value shown below is an example. Replace it with actual value
        lv_p_topics_id = 'SAMPLE_TOPIC_01'.

        lv_p_projects_id = lo_pubsub->gv_project_id.
        APPEND VALUE #( data = cl_http_utility=>encode_base64( 'Hello World!' ) )
               TO ls_input-messages.

        " Call the API
        lo_pubsub->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) ).

        " Handle the output
        IF lo_pubsub->is_success( lv_ret_code ).
          out->write( 'Message was published!' ).
        ELSE.
          out->write( 'Message was not published!' ).
        ENDIF.

        " Close the HTTP Connection
        lo_pubsub->close( ).

      CATCH /goog/cx_sdk INTO DATA(lo_exception).
        " Handle exception here
    ENDTRY.
  ENDMETHOD.
ENDCLASS.

    DEMO_PUBSUB를 클라이언트 키 이름으로 바꿉니다.

  4. 변경사항을 저장하고 활성화합니다.

  5. 애플리케이션을 실행합니다.

    1. ABAP 클래스 ZGOOG_CL_QS_PUBSUB를 선택합니다.
    2. 실행 > 다음 권한으로 실행 > ABAP 애플리케이션(콘솔)을 클릭합니다. 또는 F9를 누릅니다.

  6. 결과를 확인하려면 다음 단계를 따르세요.

    1. Google Cloud 콘솔에서 Pub/Sub로 이동합니다.

    2. SAMPLE_SUB_TOPIC_01 구독을 선택하고 메시지 탭으로 갑니다

    3. PULL 기능을 사용하여 "Hello World!" 메시지가 주제에 게시되었는지 확인합니다.

다음 단계