返回首页
当前位置: 主页 > 编程语言 > PHP教程 >

hadoop HDFS的PHP扩展—PHDFS

时间:2015-05-26 23:14来源:电脑教程学习网 www.etwiki.cn 编辑:admin

现在的业务使用hadoop hdfs来存储咨询日志,最早用了2个方案
1) 直接java,通过PHP调用java来使用
2) php 通过thrift 来调用
都感觉不是很顺畅。
后来开发phdfs 直接用php扩展的方式来简单的操作hdfs
代码地址:http://pecl.php.net/package/phdfs
Requirements
PHP Version: PHP 5.3+
ZTS Enabled ( Thread Safety )
Installing Hadoop
class phdfs {
/* variable */
public $host= "127.0.0.1" ;//hadoop ip
public $port = "9000";//hadoop port /

public function __construct(string $host,string $port);

/***
* Connect to a hdfs file system. Connect to the hdfs.
* Returns true on success, false on error.
*/
public function connect();
/***
* Disconnect from the hdfs file system. Disconnect from hdfs.
* Returns true on success, false on error.
*/
public function disconnect();
/***
* Checks if a given path exsits on the filesystem
* Returns true on success, false on error.
*/
public function exists(string $path);
/***
* Write data into an open file.
* int mode: O_WRONLY 、O_CREAT、O_APPEND
* Returns true on success, false on error.
*/
public function write(string $file,string buffer [, int $mode ]);
/***
* Read data from an open file.
* $buffer_len default 1024k
* Returns true on success, false on error.
*/
public function read(string $file[,int $buffer_len]);
/***
* Get information about a path
* Returns array on success, false on error.
*/
public function file_info(string $path);

/***
* make the given file and all non-existent parents into directories.
* Returns true on success, false on error.
*/
public function create_directory(string $path);
/***
* Rename file.
* Returns true on success, false on error.
*/
public function rename(sting $old_path,sting $new_ptah);
/***
* Get list of files/directories for a given directory-path
* Returns true on success, false on error.
*/
public function list_directory(string $path);
/***
* Get the current offset in the file, in bytes.
* Returns Current offset, false on error.
*/
public function tell(string $file [, int $buffer_len ]);
/***
* Copy file
* Returns true on success, false on error.
*/
public function copy(string $source_file,string $destination_file);
/***
* Delete file
* Returns true on success, false on error.
*/
public function delete($string $file);

}
<?php
try {
$obj = new phdfs();
$obj->port = "9000";
$obj->ip = "127.0.0.1";
$obj->connect();
//create file
$log = $obj->write("/a/b/c/test1.txt","test",O_WRONLY|O_CREAT);
//appden file
$log = $obj->write("/a/b/c/test2.txt","test",O_WRONLY|O_APPEND);
var_dump($log);
echo $obj->rename("/a/b/c/test2.txt","/a/b/c/test3.txt");
}catch (Exception $ex) {
echo $ex->getMessage();
}
?>

 

顶一下
(0)
0%
踩一下
(0)
0%
标签(Tag):php php实例教程 php5 php源代码 php基础教程 php技巧 php6 php教程
------分隔线----------------------------
------分隔线----------------------------
发表评论
请自觉遵守互联网相关的政策法规,严禁发布色情、暴力、反动的言论。
评价:
表情:
验证码:点击我更换图片
推荐内容