SAP 表批处理来源

借助 SAP Table Batch Source 插件（SAP Table 插件），您可以从 SAP 标准表和自定义表或视图中读取数据。支持从 SAP 批量数据注入 导入至 BigQuery 或任何其他受支持的目标系统， Cloud Data Fusion。该插件具有以下主要功能：

• 使用 SAP ECC、SAP S4/HANA 或 SAP BW 作为源系统
• 不使用 SAP CDC（变更数据捕获） 跟踪和提取数据源中的新数据和增量数据
• 使用批量提取模式
• 支持 SAP 表和 ABAP CDS 视图作为数据源
• 通过应用层访问 SAP 数据

您可以从以下位置读取数据：

• 透明表
• 聚簇表
• 台球桌
• ABAP CDS 观看次数
• SAP BW ADSO 对象

如需详细了解 Google Cloud 上的 SAP，请参阅 Google Cloud 上的 SAP 概览。

准备工作

设置 SAP Table 插件使用的以下系统和服务：

1. 配置 SAP ERP 系统。 此过程包括以下步骤：
   • 安装 SAP 传输文件。
   • 设置所需的 SAP 授权和角色。
   • 设置 SAP Java Connector。

2. 在 Cloud Data Fusion 中部署该插件。

   • 重要提示：请选择与 Cloud Data Fusion 版本。
   • 如果您升级 Cloud Data Fusion 的版本 实例或插件时，评估更改对 流水线的功能范围和性能

3. 在 Cloud Data Fusion 和 SAP 之间建立 RFC 连接。

   • 确保在 Cloud Data Fusion 实例和 SAP 服务器相关联。
   • 对于专用实例，请设置 VPC 网络对等互连。
   • SAP 系统和 Cloud Data Fusion 实例都必须 位于同一项目中。

配置插件

1. 转到 Cloud Data Fusion 网页界面 然后点击 Studio。
2. 检查是否选择了 Data Pipeline - Batch（而非 Realtime）。
3. 在来源菜单中，点击 Sap Table。SAP 表节点 。
4. 如需配置来源，请转到 SAP 表节点，然后点击 属性。

5. 输入以下属性。有关完整列表，请参阅 属性。

   1. 输入 SAP 表节点的标签 示例 SAP tables。

   2. 输入连接详情。您可以设置新的一次性连接 或可重复使用的现有连接。

      新增关联项

      如需添加到 SAP 的一次性连接，请按照以下说明操作 步骤：

      1. 让使用连接保持关闭状态。

      2. 在 Connection 部分中，输入以下信息 从 SAP 账号中填入以下字段：

         1. 在参考名称字段中，输入 识别此沿袭来源的连接。
         2. 在 SAP 客户端字段中，输入 特定实例或环境SAP 管理员可以提供客户端名称。
         3. 在 SAP 语言字段中，输入 SAP 登录语言。 默认值为 EN（英语）。

         4. 选择下列连接类型之一。

            • 直接（通过 SAP Application Server）。如果您选择 此默认类型，请在下方输入信息 字段：SAP 应用服务器主机、SAP 系统 编号和 SAP Router。
            • 负载均衡（通过 SAP Message Server）。如果您选择 请在以下字段中输入信息： SAP Message Server 主机、SAP Message Server 服务 或端口号、SAP 系统 ID (SID) 和 SAP 登录 群组名称。

         5. 在 SAP 表/视图名称字段中，输入 创建表或视图

         6. 提供 SAP 凭据：请向您的 SAP 管理员索要 SAP 登录用户名和密码。

         7. 在 JCo Library Cloud Storage 路径字段中，输入 SAP Java Connector (SAP JCo) 路径， 包含您上传的 SAP JCo 库文件。

         8. 根据从 SAP 映射的元数据生成架构 从 SAP 数据类型映射到相应的 Cloud Data Fusion 数据 请点击获取架构。有关详情，请参阅数据 类型映射。

         9. 可选：如需优化从 SAP 的注入负载，请输入 信息：

            1. 使用过滤条件选项，您可以根据以下条件提取记录： 选择条件，例如具有已定义的集合的列， 值。在 WHERE 子句。例如，以下查询会返回所有行 从 Roster 表中 “SchoolID”列包含的值 SchoolID > 52:

               SELECT * FROM Roster WHERE SchoolID > 52;
               

               如需了解详情，请参阅支持的过滤条件。

            2. 在要提取的行数字段中，您可以限制 通过提供一个正整数来提取数据 行，共 行。

            3. 在拆分数量字段中，您可以创建 分区来并行提取数据记录， 提高性能。拆分数量可能会影响 SAP 工作流程，因此必须谨慎选择。

            4. 在软件包大小字段中，指定 要在单个 SAP 网络调用中提取的记录。通过 软件包大小会影响性能和可用资源 因此必须谨慎选择

      可重复使用的连接

      如需重复使用现有连接，请按以下步骤操作：

      1. 开启使用网络连接。
      2. 点击浏览连接。

      3. 点击连接名称。

      如果连接不存在，如需创建可重复使用的连接，请按照下列步骤操作： 具体步骤：

      1. 点击添加连接 > SapTable。
      2. 在打开的创建 SapTable 连接页面上，输入 连接名称和说明。
      3. 在 SAP 客户端字段中，输入 特定实例或环境SAP 管理员可以提供客户端名称。
      4. 在 SAP 语言字段中，输入 SAP 登录语言。 默认值为 EN（英语）。

      5. 选择下列连接类型之一。

         • 直接（通过 SAP Application Server）。如果您选择 此默认类型，请在下方输入信息 字段：SAP 应用服务器主机、SAP 系统 编号和 SAP Router。
         • 负载均衡（通过 SAP Message Server）。如果您选择 请在以下字段中输入信息： SAP Message Server 主机、SAP Message Server 服务 或端口号、SAP 系统 ID (SID) 和 SAP 登录 群组名称。

      6. 提供 SAP 凭据：请向您的 SAP 管理员索要 SAP 登录用户名和密码值。

      7. 在 JCo Library Cloud Storage 路径字段中，输入 SAP Java Connector (SAP JCo) 路径， 包含您上传的 SAP JCo 库文件。

      8. 可选：在其他 SAP 连接属性 字段，输入必须替换 SAP JCo 的键值对 默认值。

      9. 点击创建。

属性

    SELECT * FROM table_name WHERE column_name > value; \
    SELECT * FROM table_name WHERE column_name BETWEEN value1 AND value2;
    

    SELECT * FROM table_name WHERE column_name LIKE 'pattern%';
    

    SELECT * FROM table_name WHERE column_name \
      IN ('value1', 'value2', 'value3');
    

    SELECT * FROM table_name WHERE condition1 AND condition2; \
      SELECT * FROM table_name WHERE condition1 OR condition2; \
      SELECT * FROM table_name WHERE NOT condition;
    

    SELECT * FROM table_name \
      WHERE datetime_column >= 'start_date' AND datetime_column <= 'end_date';
    

    SELECT * FROM table_name WHERE datetime_column > 'target_date';
    

    SELECT * FROM table_name \
      WHERE datetime_column >= 'target_datetime' \
      AND datetime_column <= 'target_datetime';
    

    SELECT * FROM table_name \
      WHERE (column1 = 'value1' AND column2 > value2) \
      OR (column3 = 'value3' AND column4 < value4);
    

    ( ERNAM EQ 'LEE' AND AUDAT GT '20220722' ) \
      OR ( BSTNK EQ 'PO54321065' AND BSTDK LT '20220714' )
    

    SELECT * FROM table_name \
      WHERE (column1 = 'value1' OR (column2 = 'value2' AND column3 > value3)) \
      AND column4 = 'value4';
    

    ( ERDAT EQ '20220722' OR ( ERNAM EQ 'LEE' AND VDATU GT '20210623' ) ) \
      AND FMBDAT EQ '20220722'
    

    SELECT * FROM table_name \
      WHERE column1 IN (SELECT related_column FROM other_table WHERE condition);
    

    SELECT * FROM table_name \
      WHERE (column1 = 'value1' OR column2 = 'value2') \
      AND datetime_column > 'target_datetime';
    

    ( ERDAT EQ '20220722' OR ERNAM EQ 'LEE' ) AND VDATU GT '20210623'
    

    SELECT * FROM table_name \
      WHERE datetime_column >= 'YYYY-MM-DD HH:MM:SS' \
      AND datetime_column <= 'YYYY-M
    

    SELECT * FROM table_name \
      WHERE datetime_column >= NOW() - INTERVAL X DAY;
    

    WHERE YEAR+0(4) = 2023
    

使用场景

支持两种提取上下文：

• SAP 数据库表和视图
• SAP ABAP CDS

在每个上下文中，SAP Table 插件都支持标准和自定义 数据库表和视图

限制

SAP 表格插件具有以下限制：

• 不支持联接表。
• 不支持带参数的 CDS 视图。
• 如果没有关键字段，它不支持。
• 如果已启用快照功能，则使用的软件包大小超过 30,000 都可能导致流水线故障此软件包的大小可能会有所不同，具体取决于 SAP 表中的列数。您可以计算出一个 表格大小：行大小（以字符数表示）* 5。
• 借助 Connection Manager，您最多可以浏览 1,000 个 SAP 表名称。
• 当出现数据流错误（例如接收器中出现错误）时，SAP 表插件会尝试通过调用用于清理的自定义 RFM /GOOG/RFC_READ_TABLE_CLEANUP 来清理与提取相关的所有活动 SAP 端进程。

后续步骤

• 详细了解 SAP on Google Cloud。