边缘数据源定义

边缘数据源

完成工业八爪鱼组件安装后，选择边缘数据源定义，将列出已有数据源列表，可以单击新增数据源。

数据源有七种类型，分别是数据库、API、消息队列、服务模型、数据总线、Webservice和SAP RFC，下面分别介绍每种类型的数据源：

数据库类型数据源

第一种数据源类型为数据库，现在的数据库支持以下四种：

• Sqlserver （2008企业版、2008 R2企业版、2017 CU5以上 Developer/企业版）
• MySQL （5.6以上）
• Oracle（11g以上）
• PostgreSql

API类型数据源

第三种数据源类型为消息队列，如果在边缘中部署了Kafka或者MQTT类型的消息队列，可以选择消息队列这种类型。

第四种数据源类型为服务模型，服务模型数据源将作为数据集成任务中服务模型的提供方或者依赖方。

第五种数据源类型为数据总线，可以通过DataHub把边缘端数据集成到阿里云其他大数据产品。

第六种数据源类型为Webservice，可以对接边缘端的Webservice服务。

第七种数据源类型为SAP RFC，可以对接边缘端的SAP RFC服务。

数据库类型数据源

新建数据库类型的数据源后，需要再进一步选择边缘系统的数据库型号，输入数据库的主机名称或者IP地址、名称、端口号、链接数据库的账号以及该账号的访问密码，八爪鱼应用将主动监控边缘系统的数据变化进行主动数据集成。

如果需要监控数据库的数据发生变化然后同步到云端，设置是否监控增量为是。一个数据源可能对应通过多个边缘集群进行对接，需要选择对应的边缘集群。

如果数据库是Sqlserver监控增量需要开通Sqlserver CDC服务：

首先确保SQL Server Agent（代理服务）已启动。

然后激活数据库CDC支持，执行以下SQL：

USE 数据库名;
EXEC sys.sp_cdc_enable_db

如果数据库是MySQL监控增量需要配置binlog服务：

[MySQLd]
    server-id = 123
    log_bin = MySQL-bin
    binlog_format = row
    binlog_row_image = full
    expire_logs_days = 10   

如果数据库是Oracle，配置增量监控请查看Oracle增量监控设置。

消息队列类型数据源

其中Kafka需要填写的参数为对应队列broker（多个broker用逗号隔开），鉴权是否采用SSL，如果是SSL的还需要填写用户名和密码：

其中Kafka需要填写的参数为对应队列broker（多个broker用逗号隔开），鉴权是否采用SSL，如果是SSL的还需要填写用户名和密码。

其中mqtt需要填写的参数为对应队列的实例ID，broker（多个broker用逗号隔开），鉴权是否采用SSL，如果是SSL的还需要填写用户名和密码。

API类型数据源

服务模型类型数据源

如果数字工厂的应用需要通过服务总线与边缘应用进行集成，需要创建一个一次性交付的边缘接入应用作为边缘服务的代理。首先在应用托管中创建应用，应用创建成功后在版本列表中的模型和权限中声明服务依赖和服务提供所有需要代理的接口，比如仓储管理服务（WarehouseManagementService）中所有的API：

创建好应用后，数据源类型为服务模型的边缘数据源定义中就可以选择该应用：

在进行服务集成的时候就可以选择改应用作为服务提供方或者依赖方与工业应用进行集成：

数据总线类型数据源

通过DataHub把边缘端数据集成到阿里云其他大数据产品，在定义数据总线数据源需要获取阿里云账号下数据源的访问路径、访问密钥（AccessKey）和访问密码（AccessSecurity）：

获得访问路径、访问密钥和访问密码，可以在数据源定义中填写相关的信息：

Webservice类型数据源

Webservice类型数据源可以对接边缘端的Webservice服务。

• WSDL访问路径：为访问Webservice接口的定义文件访问边缘端访问路径。
• 认证方式：如果Webservice访问不需要认证，选择无需认证选项，如果需要进行访问认证，选择Basic Auth选项，并填写访问用户名和密码。

SAP RFC类型数据源

SAP RFC类型数据源可以对接边缘端的SAP RFC服务：

• 应用服务器IP：RFC应用服务的本地服务器IP。
• 服务端编号：提供RFC的服务端编号。
• 客户端编号：提供RFC服务分配给数字工厂的客户端编号。
• 用户名：提供RFC服务分配给数字工厂的用户名。
• 密码：提供RFC服务分配给数字工厂的密码。

数据源连接测试

新建好数据源以后可以在数据源列表中进行测试并下发配置到边缘集群的八爪鱼组件中，单击测试下发：

将测试数据源IP、用户名称和密码是否正确。