尝试在 Azure 上创建目录时出现 AccessControlException

Question

我正在尝试使用天蓝色数据湖依赖项在 azureDataLake 中创建目录

<dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-data-lake-store-sdk</artifactId>
            <version>2.1.5</version>
</dependency>

使用以下方法：

private ADLStoreClient client; 
public boolean createDirectory(String path) {
        try {

            // create directory
            client.createDirectory(path);

        } catch (ADLException ex) {
            printExceptionDetails(ex);
            return false;
        } catch (Exception ex) {
            log.error(" Exception in createDirectory : {}", ex);
            return false;
        }
        return true;
    } 

我得到了这个例外：

Error creating directory /gx-zweappdhd004/home/azhdipaasssh2/ADH/Compta/1458/1533632735200/RAPPORTS/
Operation MKDIRS failed with HTTP403 : AccessControlException 

我检查了权限，我都有，所以和权限无关。

更新：

为了更具体地说明方法 isSuccessfulResponse() 内部发生的问题，确切地说是在这一行 HttpTransport.java#L137 因为 httpResponseCode 等于 403，任何人都可以解释一下。

更新2：

我发现这条线正在返回 403 状态：HttpTransport.java#L288，我还尝试评估 conn.getErrorStream().read() 并得到了这个 stream is closed，仅供参考，这是错误有时而不是总是发生。

Answer 1

我没有重现你的问题，你可以参考我的工作代码：

import com.microsoft.aad.adal4j.AuthenticationContext;
import com.microsoft.aad.adal4j.AuthenticationResult;
import com.microsoft.aad.adal4j.ClientCredential;
import com.microsoft.azure.datalake.store.ADLStoreClient;

import java.io.IOException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class CreateDirectory {

    static ADLStoreClient client;

    public static void main(String[] args) throws InterruptedException, ExecutionException, IOException {
        setup();
    }

    public static void setup() throws IOException, ExecutionException, InterruptedException {
        String APP_ID = "<your app id>";
        String APP_SECRET = "<your app secret>";
        String dirName = "/jay";
        String StoreAcct = "jaygong";

        String authority = "https://login.microsoftonline.com/<your tenant id>";
        String resourcUrl = "https://management.core.windows.net/";
        ExecutorService service = Executors.newFixedThreadPool(1);

        AuthenticationContext context = new AuthenticationContext(authority, true, service);

        // Acquire Token
        Future<AuthenticationResult> result = context.acquireToken(
                resourcUrl,
                new ClientCredential(APP_ID, APP_SECRET),
                null
        );
        String token = result.get().getAccessToken();
        System.out.println(token);

        String account = StoreAcct + ".azuredatalakestore.net";
        client = ADLStoreClient.createClient(account, token);

        client.createDirectory(dirName);
        System.out.println("finish.....");

    }
}

不要忘记向您的客户授予访问 ADL 权限。

希望对你有所帮助。