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
            lo_pubsub = NEW /goog/cl_pubsub_v1( iv_key_name = 'DEMO_PUBSUB' ).
    
            " Pass the relevant input parameters
            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).
            MESSAGE lo_exception->get_text( ) TYPE 'E'.
        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!" 메시지가 주제에 게시되었는지 확인합니다.

다음 단계