阿里云 OSS

本指南介绍如何将阿里云 OSS 配置为 Alluxio 的底层存储系统。

阿里云对象存储服务 (OSS) 是阿里云提供的一种海量、安全、高可靠的云存储服务。OSS 提供多种存储类别，帮助您管理和降低存储成本。

有关阿里云 OSS 的更多信息，请阅读其文档。

先决条件

在开始之前，请确保您已准备好以下所需信息：

<OSS_BUCKET>

在 OSS 控制台中创建一个新存储桶或使用现有存储桶

<OSS_DIRECTORY>

您要在存储桶中使用的目录，可以是创建新目录或使用现有目录

<OSS_ACCESS_KEY_ID>

用于识别用户的 ID。请参阅如何获取 AccessKey 对

<OSS_ACCESS_KEY_SECRET>

用于验证用户身份的密钥。请参阅如何获取 AccessKey 对

<OSS_ENDPOINT>

其他服务可用于访问 OSS 的域名。请参阅公共云中的区域和 OSS 端点

基本设置

使用挂载表操作添加新的挂载点，指定要在其上创建挂载的 Alluxio 路径和作为 UFS URI 的 OSS 路径。凭据和配置选项也可以作为挂载操作的一部分指定，如配置挂载点中所述。

使用 operator 创建挂载点的 ufs.yaml 示例：

apiVersion: k8s-operator.alluxio.com/v1
kind: UnderFileSystem
metadata:
  name: alluxio-oss
  namespace: alx-ns
spec:
  alluxioCluster: alluxio-cluster
  path: oss://<OSS_BUCKET>/<OSS_DIRECTORY>
  mountPath: /oss
  mountOptions:
    fs.oss.accessKeyId: <OSS_ACCESS_KEY>
    fs.oss.accessKeySecret: <OSS_ACCESS_KEY_SECRET>
    fs.oss.endpoint: <OSS_ENDPOINT>

如果不使用 operator，将 oss://<OSS_BUCKET>/<OSS_DIRECTORY> 挂载到 /oss 的示例命令：

bin/alluxio mount add --path /oss/ --ufs-uri oss://<OSS_BUCKET>/<OSS_DIRECTORY> \
  --option fs.oss.accessKeyId=<OSS_ACCESS_KEY> --option fs.oss.accessKeySecret=<OSS_ACCESS_KEY_SECRET> \
  --option fs.oss.endpoint=<OSS_ENDPOINT>

请注意，如果要挂载 OSS 存储桶的根目录，请在存储桶名称后添加一个尾部斜杠（例如 oss://OSS_BUCKET/）。

高级设置

请注意，配置选项可以指定为挂载选项或 conf/alluxio-site.properties 中的配置属性。以下各节将介绍如何将配置设置为属性，但它们也可以通过 --option <key>=<value> 设置为挂载选项。

启用 HTTPS

要启用 HTTPS 协议以与 OSS 进行安全通信，并为数据传输增加一层额外的安全性，请在 conf/alluxio-site.properties 中配置以下设置：

alluxio.underfs.oss.secure.http.enabled=true

OSS 分片上传

我们使用分片上传方法将一个文件分多个部分上传，每个部分将在一个线程中上传。上传时不会生成任何临时文件。

您可以在 conf/alluxio-site.properties 中指定其他参数以可能加快上传速度。

# Timeout for uploading part when using multipart upload.
alluxio.underfs.object.store.multipart.upload.timeout

# Thread pool size for OSS multipart upload.
alluxio.underfs.oss.multipart.upload.threads

# Multipart upload partition size for OSS. The default partition size is 16MB. 
alluxio.underfs.oss.multipart.upload.part.size

禁用 OSS 分片上传，上传方法将一次性从头到尾完整上传一个文件。您需要修改 conf/alluxio-site.properties 以包含：

alluxio.underfs.oss.multipart.upload.enabled=false

设置请求重试策略

有时访问 UFS 可能会出错，因为服务器暂时无法响应。您可以为 UFS 请求配置重试策略。

发送到 UnderFS 的每个 I/O 请求，如 getObject、putObject、MultipartUpload，Alluxio 都会检查响应。如果响应是错误，并且错误代码表明可以重试，则会根据配置中的重试策略重新提交请求。 Alluxio 将一直尝试，直到请求成功或达到最大重试次数。连续重试之间的等待间隔将从配置的基本睡眠时间逐渐增加到最大睡眠时间。

以下错误代码被归类为可重试：500 HTTP_INTERNAL_ERROR、502 HTTP_BAD_GATEWAY、503 HTTP_UNAVAILABLE、503 Slow Down 和 504 HTTP_GATEWAY_TIMEOUT。

注意：

4xx 状态码通常表示客户端错误，例如 NOT_FOUND、PERMISSION_DENIED、UNAUTHENTICATED 等。此类错误不应重试，因为问题出在客户端。
5xx 状态码通常表示服务器错误，但并非所有 5xx 错误都应重试。例如，501 HTTP_NOT_IMPLEMENTED 不应重试。

如果要为 UFS 访问请求设置重试策略，您需要修改 conf/alluxio-site.properties 以包含：

# the max number of retry in one UnderFS accessing request.
alluxio.underfs.business.retry.max.num=10

# the sleep time between the two retries after the initial failure
alluxio.underfs.business.retry.base.sleep=30ms

# the max sleep time between two retries
alluxio.underfs.business.retry.max.sleep=30s

Last updated 13 days ago