Power BI连接AnalyticDB for MySQL与Spark JDBC端点进行实时数据分析-云原生数据仓库AnalyticDB-阿里云

本文介绍如何通过Power BI连接AnalyticDB for MySQL集群并进行实时数据分析。

前提条件

已安装Power BI。
说明
本文示例Power BI版本为2.143.878.0 Power BI Desktop，语言为英文。
如果您需要通过公网连接AnalyticDB for MySQL集群，请先申请外网地址。
连接Spark JDBC端点时，还需创建Spark Interactive型资源组。

Power BI连接ADB MySQL端点

使用定制连接器连接（推荐）

定制连接器和PowerBI内置MySQL连接器均支持使用导入模式访问AnalyticDB for MySQL的数据。此外，定制连接器还支持通过直接查询模式访问AnalyticDB for MySQL的数据。因此建议您通过定制连接器连接AnalyticDB for MySQL集群，以满足您不同模式访问数据的需求。

步骤一：安装MySQL ODBC驱动

下载并安装Microsoft Visual C++ 2010 Service Pack 1 Redistributable Package MFC。
下载并安装5.1.13版本的MySQL ODBC Driver。
打开ODBC数据源管理程序（64位），在驱动程序页签下查看MySQL ODBC Driver是否已成功安装。

步骤二：安装AnalyticDB for MySQL连接器

下载AnalyticDB.MySQL.mez连接器。
将AnalyticDB.MySQL.mez连接器移动到PowerBI目录（默认路径为： [Documents]\Power BI Desktop）下的Custom Connectors文件夹中。如果该文件夹不存在，请新建Custom Connectors文件夹。
重要
- [Documents]指代的是当前账号的文档目录，如Administrator账号的文档目录默认为 C:\Users\Administrator\Documents\Power BI Desktop。
- 不同账号的文档目录是不一样的，Power BI无法加载其他账号文档目录下的连接器，因此各账号需要独立安装维护连接器。
打开PowerBI，单击Options and settings > Options。
单击security，在Data Extensions区域，勾选(Not Recommended) Allow any extension to load without validation or warning，单击OK。
在弹出的Change Requires Restart对话框中单击OK。然后重启PowerBI。

步骤三：使用PowerBI连接AnalyticDB for MySQL

打开PowerBI，单击Get data from other sources。
在弹出的Get Data对话框中，选择AnalyticDB MySQL(Beta)(Custom)，单击Connect。
在弹出的Connecting to a third-party service对话框单击Continue。

在弹出的AnalyticDB MySQL database对话框中，配置如下参数：

参数说明：

参数	是否必填	说明
Server	是	AnalyticDB for MySQL的连接地址和端口号。格式为`<连接地址>:端口号`。连接地址：如果PowerBI安装在ECS上，且ECS与AnalyticDB for MySQL集群属于同一VPC，则填写VPC地址。如果PowerBI安装在本地服务器上，则填写公网地址。端口号固定为3306。
Database	否	AnalyticDB for MySQL集群的数据库名称。
Connection timeout in seconds	否	连接AnalyticDB for MySQL集群的超时时间。单位为秒（s）。
Read timeout in seconds	否	执行读取数据操作的最大时间。单位为秒（s）。
Write timeout in seconds	否	执行写入数据操作的最大时间。单位为秒（s）。
Don't cache results of forward-only cursors	否	Power BI在使用只前向光标查询数据时，不缓存查询结果。
Force use of forward-only cursors	否	Power BI在执行查询时强制使用只前向光标。
Native query	否	SQL查询语句。该值为空，会在步骤6的Navigator对话框中列出AnalyticDB for MySQL集群的所有表。
Data Connectivity mode	是	数据连接模式。取值如下： Import：导入模式。 DirectQuery：直接查询模式。

在AnalyticDB MySQL对话框中，配置如下参数，单击Connect。
参数说明：
参数
说明
User name
AnalyticDB for MySQL集群的数据库账号。
Password
AnalyticDB for MySQL集群的数据库账号的密码。
在弹出的Navigator对话框中，选择目标数据表，右侧预览数据无误后单击Load。
完成配置之后，您可以根据该数据源开始数据分析。更多详细内容请参见PowerBI官方文档。

使用PowerBI内置MySQL连接器连接

下载安装MySQL Connector。
打开PowerBI，单击Get data from other sources。
选择MySQL database，然后单击Connect。
说明
Power BI将自动检测您的系统是否安装MySQL Connector，若未安装，请根据提示安装MySQL Connector。

在弹出的MySQL database对话框中，配置如下参数后，单击OK。

参数说明：

参数

是否必填

说明

Server

是

AnalyticDB for MySQL的连接地址和端口号。格式为<连接地址>:端口号。

如果PowerBI安装在ECS上，且ECS与AnalyticDB for MySQL集群属于同一VPC，则填写VPC地址。
如果PowerBI安装在本地服务器上，则填写公网地址。

Database

否

AnalyticDB for MySQL集群的数据库名称。

在MySql database对话框中，选择Database页签，配置如下参数后，单击Connect。
参数说明：
参数
是否必填
说明
User name
是
AnalyticDB for MySQL集群的数据库账号。
Password
是
AnalyticDB for MySQL集群的数据库账号的密码。
在弹出的Encryption Support对话框中，单击OK。
在弹出的Navigator对话框中，选择目标数据表，右侧预览数据无误后单击Load。
完成配置之后，您可以根据该数据源开始数据分析。更多详细内容请参见PowerBI官方文档。

Power BI连接Spark JDBC端点

注意事项

Power BI连接Spark JDBC端点后，仅支持读写表引擎为XUANWU的表，不支持读写表引擎为XUANWU_V2的表。

操作步骤

下载驱动程序。
Power BI支持通过Microsoft Spark ODBC Driver或Simba Spark ODBC Driver驱动程序连接Spark Interactive型资源组，您可以根据业务需求，下载对应驱动程序。
- 下载Microsoft Spark ODBC Driver驱动程序。
- 下载Simba Spark ODBC Driver驱动程序。

创建数据源。

打开ODBC数据源管理程序（64位），在用户 DSN页签下单击添加。
在弹出的创建数据源对话框中选择步骤1下载的驱动，然后单击完成。

在弹出的Microsoft Spark ODBC Driver DSN Setup或Simba Spark ODBC Driver DSN Setup对话框中配置如下参数：

参数	说明
Data Source Name	数据源名称。您可以自定义。
Description	数据源描述。您可以自定义。
Host(s)	Spark Interactive型资源组连接地址。获取方法，请参见准备工作。
Port	Spark Interactive型资源组的端口号，固定为10000。
Database	AnalyticDB for MySQL的数据库名称。
Mechanism	鉴权方式。本文选择User Name and Password。
User Name	AnalyticDB for MySQL的数据库账号及Spark Interactive型资源组名称。格式为`资源组名称/数据库账号名称`。例如：本文示例资源组名称为testjob，数据库账号名称为test，此处填写为`testjob/test`。
Password	AnalyticDB for MySQL数据库账号的密码。
Thrift Transport	连接方式。固定选择SASL。

单击SSL Options，在弹出的SSL Options对话框中取消勾选Enable SSL，单击OK。
单击Advanced Options，在弹出的Advanced Options对话框中勾选Get Tables with Query。
单击Server Side Properties，取消勾选Apply properties with queries，然后单击OK。
在Microsoft Spark ODBC Driver DSN Setup或Simba Spark ODBC Driver DSN Setup对话框中，单击Test，测试连通性。
如果返回信息中包含SUCCESS，则表示ODBC连接AnalyticDB for MySQL Spark Interactive资源组成功。

打开PowerBI，单击Get data from other sources。
在弹出的Get Data对话框中，选择ODBC，单击Connect。
在弹出的From ODBC对话框中，选择步骤2创建的数据源，然后单击OK。本示例数据源为adb_test。
在弹出的ODBC driver对话框中，单击Windows页签，选择Use my current credentials，然后单击Connect。
在弹出的Navigator对话框中，选择目标数据表，右侧预览数据无误后单击Load。
完成配置之后，您可以根据该数据源开始数据分析。更多详细内容请参见PowerBI官方文档。