本快速入门介绍了如何创建一个程序,以使用 Pub/Sub API 通过 SAP BTP 版本的 ABAP SDK for Google Cloud 将“Hello World!”消息发布到 Pub/Sub 主题。
准备工作
在运行本快速入门之前,请确保您或您的管理员已满足以下前提条件:
您拥有一个 Google Cloud 账号和项目。
您的项目已启用结算功能。了解如何确认您的项目是否已启用结算功能。
已安装并配置 SAP BTP 版本的 ABAP SDK for Google Cloud。了解如何安装和配置 ABAP SDK for Google Cloud 的 SAP BTP 版本。
已设置用于访问 Google Cloud APIs 的身份验证。了解如何设置身份验证。
您有权访问 SAP BTP、ABAP 环境。
您已在最新的 Eclipse 平台上下载并安装了最新的 ABAP 开发工具 (ADT)。
您已创建 ABAP Cloud 项目。
为服务账号授予 IAM 角色
roles/pubsub.publisher
。确保已在 Google Cloud 项目中启用 Pub/Sub API。
创建 Pub/Sub 主题
SAMPLE_TOPIC_01
并向其中添加拉取订阅SAMPLE_SUB_TOPIC_01
。如需了解详情,请参阅创建主题和创建订阅。
创建 ABAP 类以将消息发布到 Pub/Sub 主题
创建软件包:
- 在 ADT 中,转到 Project Explorer。
- 右键点击软件包
ZLOCAL
,然后选择新建 > ABAP 软件包。 为软件包输入以下详细信息:
- 名称:输入
ZABAPSDK_TEST
。 - 说明:输入
ABAP SDK Test Package
。
- 名称:输入
点击下一步。
在选择传输请求对话框中,选中创建新请求复选框。
输入传输请求的说明。
点击完成。
创建 ABAP 类以调用 Pub/Sub API:
- 右键点击 ABAP 软件包,然后选择新建 > ABAP 类。
为 ABAP 类输入以下详细信息:
- 名称:输入
ZGOOG_CL_QS_PUBSUB
。 - 说明:输入
Quick start for Pub/Sub API
。
- 名称:输入
点击下一步。
选择传输请求,然后点击完成。
在代码编辑器中,将默认代码替换为以下代码段:
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
替换为客户端密钥名称。保存并启用更改。
运行您的应用:
- 选择 ABAP 类
ZGOOG_CL_QS_PUBSUB
。 - 依次点击运行 > 运行方式 > ABAP 应用(控制台)。或者,按
F9
。
- 选择 ABAP 类
如需验证结果,请按以下步骤操作:
在 Google Cloud 控制台中,前往 Pub/Sub。
选择订阅
SAMPLE_SUB_TOPIC_01
,然后前往消息标签页。使用拉取功能检查“Hello World!”消息是否已发布到主题。
后续步骤
- 阅读使用 SAP BTP 版本的 ABAP SDK for Google Cloud 进行应用开发指南。
- 在 Cloud 论坛上提出问题并在社区中探讨 ABAP SDK for Google Cloud。