如何在 Ceph 对象存储中存储对象

Question

>我已经在 3 个节点上部署了一个 Ceph 集群，并创建了msd和rgw。我有 3 台名为 ceph1、ceph2 和 ceph3 的机器。

• Ceph1 运行 OSD、MON、MDS 和 RWG
• Ceph2 运行 OSD
• Ceph3 运行 OSD

我已经创建了一个带有radosgw-admin user create命令的用户。

现在我想使用 swift api 访问 ceph 集群并创建一个容器。为此，我编写了以下java代码：

import org.javaswift.joss.client.factory.AccountConfig;
import org.javaswift.joss.client.factory.AccountFactory;
import org.javaswift.joss.client.factory.AuthenticationMethod;
import org.javaswift.joss.model.Account;
import org.javaswift.joss.model.Container;
import org.javaswift.joss.model.StoredObject;
import java.io.File;
import java.io.IOException;
import java.util.*;
public class Example {
public static void main(String[] args) {
String username = "sahoo";
String password = "IM8K5GAQIXHFRAKYS761";
String authUrl  = "http://ceph1:7480/";
AccountConfig config = new AccountConfig();
config.setUsername(username);
config.setPassword(password);
config.setAuthUrl(authUrl);
config.setAuthenticationMethod(AuthenticationMethod.BASIC);
Account account = new AccountFactory(config).createAccount();
Container container = account.getContainer("container-name");
container.create();
}
}

但是在运行代码时，我收到以下异常：

Exception in thread "main" java.lang.NullPointerException
at org.javaswift.joss.command.impl.identity.BasicAuthenticationCommandImpl.getReturnObject(BasicAuthenticationCommandImpl.java:35)
at org.javaswift.joss.command.impl.identity.BasicAuthenticationCommandImpl.getReturnObject(BasicAuthenticationCommandImpl.java:18)
at org.javaswift.joss.command.impl.core.AbstractCommand.call(AbstractCommand.java:51)
at org.javaswift.joss.client.impl.ClientImpl.createAccount(ClientImpl.java:97)
at org.javaswift.joss.client.impl.ClientImpl.createAccount(ClientImpl.java:27)
at org.javaswift.joss.client.core.AbstractClient.authenticate(AbstractClient.java:35)
at org.javaswift.joss.client.factory.AccountFactory.createAccount(AccountFactory.java:30)
at Example.main(Example.java:24)

任何人都可以帮助我解决为什么我会得到异常以及我们需要传递给config.setAuthUrl()的确切内容.

Answer 1

首先，你需要创建子用户来使用 swift API。

sudo radosgw-admin subuser create radosgw-admin subuser create --uid={uid} --subuser={uid} --access=[ read | write | readwrite | full ]

参考： http://docs.ceph.com/docs/giant/radosgw/admin/

要为用户创建子用户(Swift 接口(，必须指定用户 ID (--uid={用户名}(、子用户 ID 和子用户的访问级别。

然后，我们需要将 Ceph RGW 的 URL 传递给config.setAuthUrl()。最好使用swift命令快速进行测试。

例如，如果可以通过以下命令确认创建容器：

# swift -V 1.0 -A http://ceph.example.com/auth/v1 -U foo:swift -K testsecret post test-container

然后，您可以指定以下变量：

• config.setUsername(( ...foo:swift
• config.setPassword(( ...testsecret
• config.setAuthUrl(( ...http://ceph.example.com/auth/v1