Alluxio集成CephFS作为底层存储

Slack Docker Pulls GitHub edit source

该指南介绍如何配置Alluxio以使用CephFS作为底层文件系统。Alluxio使用CephFS 目前，支持两种不同类型的UFS CephFS：

初始步骤

首先，在你的机器上必须安装Alluxio二进制包。你可以自己编译Alluxio，或者下载二进制包

其次，在你的机器上需要安装以下包:

cephfs-java
libcephfs_jni
libcephfs2

以上，包的安装请参考ceph包安装，

再次，建立软连：

$ ln -s /usr/lib64/libcephfs_jni.so.1.0.0 /usr/lib64/libcephfs_jni.so
$ ln -s /usr/lib64/libcephfs.so.2.0.0 /usr/lib64/libcephfs.so
$ java_path=`which java | xargs readlink | sed 's#/bin/java/##g'`
$ ln -s /usr/share/java/libcephfs.jar $java_path/jre/lib/ext/libcephfs.jar

最后，下载CephFS Hadoop jar包:

$ curl -o $java_path/jre/lib/ext/hadoop-cephfs.jar -d https://download.ceph.com/tarballs/hadoop-cephfs.jar

配置Alluxio

为了配置Alluxio以使用底层文件系统，需要修改alluxio-site.properties和core-site.xml文件。如果文件不存在，根据模板创建配置文件。

$ cp conf/alluxio-site.properties.template conf/alluxio-site.properties
$ cp conf/core-site.xml.template conf/core-site.xml

向conf/alluxio-site.properties文件添加以下代码：

alluxio.underfs.cephfs.conf.file=<ceph-conf-file>
alluxio.underfs.cephfs.mds.namespace=<ceph-fs-name>
alluxio.underfs.cephfs.mount.point=<ceph-fs-dir>
alluxio.underfs.cephfs.auth.id=<client-id>
alluxio.underfs.cephfs.auth.keyring=<client-keyring-file>

向conf/alluxio-site.properties文件添加以下代码：

alluxio.underfs.hdfs.configuration=${ALLUXIO_HOME}/conf/core-site.xml

向conf/core-site.xml文件添加以下代码：

<configuration>
  <property>
    <name>fs.default.name</name>
    <value>ceph://mon1,mon2,mon3/</value>
  </property>
  <property>
    <name>fs.defaultFS</name>
    <value>ceph://mon1,mon2,mon3/</value>
  </property>
  <property>
    <name>ceph.data.pools</name>
    <value>${data-pools}</value>
  </property>
  <property>
    <name>ceph.auth.id</name>
    <value>${client-id}</value>
  </property>
  <property>
    <name>ceph.conf.options</name>
    <value>client_mount_gid=${gid},client_mount_uid=${uid},client_mds_namespace=${ceph-fs-name}</value>
  </property>
  <property>
    <name>ceph.root.dir</name>
    <value>${ceph-fs-dir}</value>
  </property>
  <property>
    <name>ceph.mon.address</name>
    <value>mon1,mon2,mon3</value>
  </property>
  <property>
    <name>fs.AbstractFileSystem.ceph.impl</name>
    <value>org.apache.hadoop.fs.ceph.CephFs</value>
  </property>
  <property>
    <name>fs.ceph.impl</name>
    <value>org.apache.hadoop.fs.ceph.CephFileSystem</value>
  </property>
  <property>
    <name>ceph.auth.keyring</name>
    <value>${client-keyring-file}</value>
  </property>
</configuration>

使用CephFS本地运行Alluxio

完成所有的配置之后，你可以本地运行Alluxio,观察是否一切运行正常。

./bin/alluxio format
./bin/alluxio-start.sh local

该命令应当会启动一个Alluxio master和一个Alluxio worker，可以在浏览器中访问http://localhost:19999查看master Web UI。

./bin/alluxio fs mkdir /mnt/cephfs
./bin/alluxio fs mount /mnt/cephfs cephfs://mon1\;mon2\;mon3/

接着，你可以运行一个简单的示例程序：

./bin/alluxio runTests --path cephfs://mon1\;mon2\;mon3/

运行成功后，访问你的alluxio /mnt/cephfs 和 cephfs 目录，确认其中包含了由Alluxio创建的文件和目录default_tests_files/Basic_CACHE_THROUGH _。 前者，通过Alluxio的[Command Line Interface](/en/operation/User-CLI.html)可被访问； 后者，通过ceph-fuse或mount的方式使用POSIX APIs[Mounting CephFS](https://docs.ceph.com/en/latest/cephfs/#mounting-cephfs)可被访问。

./bin/alluxio fs mkdir /cephfs-hadoop
./bin/alluxio fs mount /cephfs-hadoop ceph://mon1\;mon2\;mon3/

接着，你可以运行一个简单的示例程序：

./bin/alluxio runTests --path ceph://mon1\;mon2\;mon3/

运行成功后，访问你的alluxio /mnt/cephfs-hadoop 和 cephfs 目录，确认其中包含了由Alluxio创建的文件和目录default_tests_files/Basic_CACHE_THROUGH _。 前者，通过Alluxio的[Command Line Interface](/en/operation/User-CLI.html)可被访问； 后者，通过ceph-fuse或mount的方式使用POSIX APIs[Mounting CephFS](https://docs.ceph.com/en/latest/cephfs/#mounting-cephfs)可被访问。