PredictionIO使用PHP的SDK收集数据

浏览数：105 / 时间：2015年06月09日

PredictionIO 安装：http://php2012web.blog.51cto.com/5585213/1631301

官方收集数据文档地址：https://docs.prediction.io/datacollection/eventapi/

或 https://docs.prediction.io/templates/recommendation/quickstart/

PredictionIO收集数据支持：Python,PHP,Ruby,Java,REST(API)；其中 TEST 是原生接口（即直接通过URL地址访问服务器API）。

PredictionIO收集数据需要创建一个应用（类似数据库中创建一个库）。

进入PredictionIO安装目录；

或者把PredictionIO加载到系统PATH中

PATH=$PATH:/PredictionIO安装目录/bin; export PATH

PredictionIO数据收集应用是通过事件服务器 eventserver 接收，然后存储（默认使用Apache HBase作为数据存储），所以要正常使用API必需启动 eventserver服务，当然通过 pio-start-all 默认所有相关服务都会启动，无需使用下面的命令再次启动。

启动eventserver事件服务器：

pio eventserver [--ip <value>] [--port <value>] [--stats]

参数 --ip 是指定访问IP地址，默认为localhost。

--port 是指定访问端口号，默认为 7070。

--stats 是查看状态

创建应用

pio app new MyAppName

如：

[root@localhost /]# pio app new user
[WARN] [NativeCodeLoader] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
[INFO] [HBLEvents] The table predictionio_eventdata:events_2 doesn‘t exist yet. Creating now...
[INFO] [App$] Initialized Event Store for this app ID: 2.
[INFO] [App$] Created new app:
[INFO] [App$]       Name: user
[INFO] [App$]         ID: 2
[INFO] [App$] Access Key: 1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1

注意：MyAppName 是当前应用的名称（类似数据库的库名），在SDK中 Name 与 Access Key是会使用到。

查看所有应用

[root@localhost /]# pio app list
[INFO] [App$]                 Name |   ID |                                                       Access Key | Allowed Event(s)
[INFO] [App$]                 user |    1 | 1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1 | (all)
[INFO] [App$] Finished listing 1 app(s).

删除应用

pio app delete MyAppName

只删除应用数据

pio app data-delete MyAppName

如：

[root@localhost /]# pio app data-delete user
[INFO] [App$] The data of the following app will be deleted. Are you sure?
[INFO] [App$]     App Name: user
[INFO] [App$]       App ID: 1
[INFO] [App$]  Description: None
Enter ‘YES‘ to proceed: YES
[WARN] [NativeCodeLoader] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
[INFO] [HBLEvents] Removing table predictionio_eventdata:events_2...
[INFO] [App$] Removed Event Store for this app ID: 2
[INFO] [HBLEvents] The table predictionio_eventdata:events_2 doesn‘t exist yet. Creating now...
[INFO] [App$] Initialized Event Store for this app ID: 2.
[INFO] [App$] Done.

注意：中间会要求确认操作，输入YES一定要大写。

eventserver事件服务器API：

API访问地址： http://localhost:7070/events.json?accessKey=yourAccessKeyString

yourAccessKeyString 是访问应用的 Access Key 值，当PHP SDK不能正常访问时，可以直接在浏览器中打开对应的API地址，查看服务器是否正常。

API参数：（所有名称的避开使用 $或 pio_ 开头，如"$set"或"pio_set"，红色的参数名是要注意的，参数是以POST方式操作）

参数名	数据类型	要求	功能说明
event	字符串	必需	事件名称或特殊事件名
entityType	字符串	必需	实体类型（类似关系数据库的表名）
entityId	字符串	必需	实体ID（类似关系数据库的ID，必需保证唯一）
targetEntityType	字符串	可选	与之关联的实体类型
targetEntityId	字符串	可选	与之关系实体类型ID（类似关系数据库的关联ID）
properties	JSON	可选	该记录的相关所有属性集，以【名/值】对形式存在。
eventTime	字符串	可选	记录生成时间，默认是服务器当前时间，实际应用中最好直接这个时间。必需以ISO 8601格式（如 2004-12-13T21:39:45.618Z,或2014-09-09T16:17:42.937-08:00）

PHP SDK 安装包及规范文档：https://packagist.org/packages/predictionio/predictionio

GIT库地址：

规范文档：https://github.com/PredictionIO/PredictionIO-PHP-SDK.git

安装包：https://github.com/PredictionIO/PredictionIO-PHP-SDK/tree/master

要求：

git ，php>=5.4.0 ，composer

PredictionIO 需要PHP的 cURL 扩展，编译时需要添加 --with-curl[=DIR] 选项（[=DIR]是指定libcurl安装目录需要包含lib和include的目录路径。在include目录中必须有一个名为curl，包含了easy.h和curl.h的文件夹。lib文件夹里应该有一个名为libcurl.a的文件）。如果没有指定libcurl安装目录，则使用默认安装目录。

安装使用composer 需要PHP的openssl扩展，编译时需要添加 --with-openssl[=DIR] 选项。

PHP部分./configure时缺失包报错：

checking for cURL in default path... not found
configure: error: Please reinstall the libcurl distribution -
easy.h should be in /include/curl/

缺少 curl-devel

checking libxml2 install dir... no
checking for xml2-config path... 
configure: error: xml2-config not found. Please check your libxml2 installation.

缺少 libxml2-devel

checking for RAND_egd... no
checking for pkg-config... /usr/bin/pkg-config
configure: error: Cannot find OpenSSL‘s <evp.h>

缺少 openssl-devel

安装git: http://git-scm.com/downloads

或者直接使用

yum install git

安装composer：（composer 是基于PHP的一个脚本程序）

下载地址：https://getcomposer.org/

安装：

curl -sS https://getcomposer.org/installer | php

或

php -r "readfile(‘https://getcomposer.org/installer‘);" | php

如果报如下类似错误：

curl: (56) SSL read: errno -5961
Parse error: syntax error, unexpected end of file, expecting variable (T_VARIABLE) or heredoc end (T_END_HEREDOC) or ${ (T_DOLLAR_OPEN_CURLY_BRACES) or {$ (T_CURLY_OPEN) in - on line 885

则可以先下载再执行安装：

wget https://getcomposer.org/installer
chmod 777 installer
./installer

如果报如下类似错误：

Download failed: file_get_contents(https://getcomposer.org/composer.phar): failed to open stream: HTTP request failed!

那就手动下载

wget https://getcomposer.org/composer.phar

说明：其实composer就是名为composer.phar一个PHP脚本程序，所谓的安装只是把这个脚本文件给下载出来。官方网站上说的局部安装则是把这个脚本文件下载到对应的待处理依赖包（含有composer.json文件）目录下再执行这个脚本，而全局安装则是把这个脚本添加到系统的PATH目录下，好让这个脚本在任意地方调用而时不受脚本所在目录影响。

全局处理可有多种方式：

例：

永久生效：(把composer直接移动到PHP的默认安装启动目录下，当然也可以指定到其它PATH目录)

mv composer.phar /usr/local/bin/composer

临时生效：(把composer追加到当前终端PATH目录中，当这个终端关闭后，操作失效，即无法再任意地方调用composer，注意composer得先修改下文件名，/var/composer/bin是composer所在目录)

mv composer.phar composer
PATH=$PATH:/var/composer/bin;export PATH

注意：全局方式安装只是针对会多次使用到composer时提供一种方便，而不用每次使用composer都要下载composer.phar或移动到待依赖处理包所在目录下；而局部方式则是针对使用次数少时的一种临时处理方案，用完就不要，或者保存起来，下次用再复制过去。

下载PHP SDK包：(这个包下载后不能直接使用，必需使用composer处理依赖并下载对应的文件)

git clone https://github.com/PredictionIO/PredictionIO-PHP-SDK /var/tmp/sdk

SDK包依赖处理：

进入SDK下载所在目录

根据安装composer的方式，选择下载依赖文件：（局部处理方式，必需先下载composer.phar到当前SDK目录下）

php composer.phar install

或（全局处理方式）

composer install

注意：处理依赖会下载一批php文件，有时会因为网络问题报错，只能再重新调用依赖安装命令。

如下类似错，大部分是网络异常，下载文件失败。可以手动查看下对应的文件是否能成功下载。

  [Composer\Repository\RepositorySecurityException]                            
  The contents of https://packagist.org/p/provider-latest$62dd7ff0a317764ec6e  
  27022b357464cbbf1275096f9028d1b0a03925c845ac2.json do not match its signatu  
  re. This should indicate a man-in-the-middle attack. Try running composer a  
  gain and report this if you think it is a mistake.

PHP SDK收集数据（在PHP SDK安装包目录下）

创建收集文件（收集使用SDK的 EventClient 对象）

vim user.php

写入代码：（收集数据，是尽可能多收集，以便后续使用）

注意：Access Key的值需要与当前创建应用相同，可以使用 pio app list 查看

/*   加载自动加载文件，
 *   命名空间与目录对应列表：(以当前PHP SDK安装目录为根目录)
 *   predictionio         /src/predictionio
 *   React\Promise        /vendor/react/promise/src
 *   GuzzleHttp\Stream    /vendor/guzzlehttp/streams/src
 *   GuzzleHttp\Ring      /vendor/guzzlehttp/ringphp/src
 *   GuzzleHttp           /vendor/guzzlehttp/guzzle/src
 *   
 * 注意：默认在/src/predictionio 目录下生成的 EventClient.php 只是添加部分功能，实际应用中可以去扩展这个文件。
*/
require_once("vendor/autoload.php");

use predictionio\EventClient;

//创建应用事件客户端对象，注意第一个参数是PredictionIO生成应用的Access Key ，第二个参数是访问API的地址（可以不传默认是本地，端口号是7070）。
$client = new EventClient(‘1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1‘,‘http://127.0.0.1:7070‘);

// 用户行为
$client->createEvent(array(
   ‘event‘ => ‘user‘,                //应用名（pio app new MyAppName 中的MyAppName）
   ‘entityType‘ => ‘action‘,         //实体类型，类似表名，可以根据需求定义。
   ‘entityId‘ => 121,                //这条记录的ID值，最好保证唯一。
   ‘targetEntityType‘ => ‘entity‘,   //关联实体类型，类似关联表名。
   ‘targetEntityId‘ => 1,            //关联实体类型的ID，类似关联表记录的ID
   ‘properties‘ => array(            //该记录的数据体，根据实际要求添加，尽可能的多收集标识。
       ‘url‘=> ‘http://PredictionIO.com/‘,
       ‘referer‘=> ‘http://PredictionIO.com/list/‘,
       ‘platform‘=> ‘pc‘,
       )
));

// 用户数据
$client->createEvent(array(
   ‘event‘ => ‘user‘,                //应用名
   ‘entityType‘ => ‘entity‘,         //实体类型，即表名。
   ‘entityId‘ => 1,                  //实体类型记录ID。
   ‘properties‘ => array(            //该记录的数据体。
       ‘name‘=> ‘张三‘,
       ‘age‘=> ‘15‘,
       ‘sex‘=> ‘男‘,
       )
));

保存后通过PHP命令行运行：

php user.php

如果报如下错：（可以重新启动下PredictionIO，可以查看：https://docs.prediction.io/resources/faq/）

Fatal error: Uncaught exception ‘predictionio\PredictionIOAPIError‘ with message ‘Client error response [url] http://127.0.0.1:7070/events.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1 [status code] 401 [reason phrase] Unauthorized‘ in /var/tmp/sdk/src/predictionio/BaseClient.php:59
Stack trace:
#0 /var/tmp/sdk/src/predictionio/EventClient.php(249): predictionio\BaseClient->sendRequest(‘POST‘, ‘/events.json?ac...‘, ‘{"event":"user"...‘)
#1 /var/tmp/sdk/test.php(31): predictionio\EventClient->createEvent(Array)
#2 {main}
  thrown in /var/tmp/sdk/src/predictionio/BaseClient.php on line 59

其它错误可以检查下PHP版本，curl扩展等是否达到要求。

收集数据调试（这些功能并不包含在SDK中）

查看是所有当前应用数据命令：（注意 accessKey 是所创建应用的 access Key 值）

curl -i -X GET http://localhost:7070/events.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1

正确的结果：

HTTP/1.1 200 OK
Server: spray-can/1.3.2
Date: Wed, 06 May 2015 07:15:32 GMT
Content-Type: application/json; charset=UTF-8
Content-Length: 594

[{"eventId":"rhfb-lPDpW1R6kTf14pTiQAAAU0oEv2ygw0_hXPBpTY","event":"user","entityType":"entity","entityId":"1","properties":{"name":"张三","age":"15","sex":"男"},"eventTime":"2015-05-06T07:14:02.802Z","creationTime":"2015-05-06T07:14:02.802Z"},
{"eventId":"2cmHXLcgockKGfq9gVNRPAAAAU0oEvrQlk0XBQuon0Q","event":"user","entityType":"action","entityId":"121","targetEntityType":"entity","targetEntityId":"1","properties":{"url":"http://PredictionIO.com/","referer":"http://PredictionIO.com/list/","platform":"pc"},"eventTime":"2015-05-06T07:14:02.064Z","creationTime":"2015-05-06T07:14:02.064Z"}]

查看指定事件数据命令：（注意：<eventId>是要查询的事件ID，通过上面的命令中可以得到对应的事件ID，accessKey 同上）

curl -i -X GET http://localhost:7070/events/<eventId>.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1

如：

curl -i -X GET http://localhost:7070/events/rhfb-lPDpW1R6kTf14pTiQAAAU0oEv2ygw0_hXPBpTY.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1

删除指定事件数据命令：（注意删除与查询事件数据只是请求方式不同，一个是GET一个是DELETE，参数均相同）

curl -i -X DELETE http://localhost:7070/events/<eventId>.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1

其它API参数列表：

startTime 开始时间，ISO8601格式。过滤条件为 eventTime>=startTime。

untilTime 指定时间以前，ISO8601格式。过滤条件为 eventTime<untilTime。

entityType 指定实体类型。

entityId 指定实体ID

limit 限制提取记录数，默认为20

reversed 默认是false (从小到大，以creationTime时间记录)

例如：（注意在命令行中参数出现 & 符号时这个参数必需加引号）

curl -i -X GET "http://localhost:7070/events.json?accessKey=1rqDilLgSOjVIKI2SAiLSIsHecSHfq4b0KrGRh8RAbIcXL8dpjOwyTIgxEs6QiU1&reversed=true&entityType=user&entityId=1"

本文出自 “秋风扫落叶” 博客，请务必保留此出处http://php2012web.blog.51cto.com/5585213/1643957

郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。

PredictionIO使用PHP的SDK收集数据