Как исправить В указанном ресурсе отсутствует ошибка при использовании службы хранилища таблиц AZURE от клиента REST - PullRequest
Новая
       20

Как исправить В указанном ресурсе отсутствует ошибка при использовании службы хранилища таблиц AZURE от клиента REST

1 голос
/ 04 апреля 2019

Возникла проблема при использовании службы REST Azure Storage Table.Даже ресурс присутствует в моей учетной записи хранения при использовании службы (вставка сущности) с ошибкой «Указанный ресурс не существует» со статусом ответа 400.

Я пытался с помощью Jersy restful API для использования AZURE Storage Service API.В соответствии с документацией Microsoft я пытался использовать эту услугу.Ссылка на документ: https://docs.microsoft.com/en-us/rest/api/storageservices/authorize-with-shared-key

2) Я также пытался выполнить операцию GET ... в этом случае Ответ возвращает 400: причина = Значение одного из заголовков HTTP не в правильном формате.

3) То же самое и с POSTMAN к тому времени также столкнулись с тем же ответом, что и выше. 

import java.net.*;
import java.util.*;
import java.text.*;
import javax.crypto.*;
import javax.crypto.spec.*;
import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.Entity;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.apache.commons.codec.binary.Base64;

import com.fasterxml.jackson.core.JsonGenerationException;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;

public class InsertEntity_new {
    private static Base64 base64 = new Base64();

    public static void signRequestSK(WebTarget target, String account, String key, Client client) throws Exception {
        ObjectMapper mapper = new ObjectMapper();
        SimpleDateFormat fmt = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss");
        fmt.setTimeZone(TimeZone.getTimeZone("GMT"));
        String date = fmt.format(Calendar.getInstance().getTime()) + " GMT";

        StringBuilder sb = new StringBuilder();
        sb.append("POST\n"); // method
        sb.append('\n'); // md5 (optional)
        sb.append('\n'); // content type
        sb.append('\n'); // legacy date
        sb.append("x-ms-date:" + date + '\n'); // headers
        sb.append("x-ms-version:2009-09-19\n");
        sb.append("/" + account + request.getURL().getPath()); //CanonicalizedResource

        // System.out.println(sb.toString());
        Mac mac = Mac.getInstance("HmacSHA256");
        mac.init(new SecretKeySpec(base64.decode(key), "HmacSHA256"));
        String authKey = new String(base64.encode(mac.doFinal(sb.toString().getBytes("UTF-8"))));
        String auth = "SharedKeyLite " + account + ":" + authKey;
        client.property("x-ms-date", date);
        client.property("Authorization", auth);
        client.property("x-ms-version", "2009-09-19");


        String jsonInString = "{\"PartitionKey\":\"mypartitionkey\",\"RowKey\":\"001\",\"Email\":\"ramesh@gmail.com\",\"PhoneNumber\":\"908265370\"}";
        Response resp = target.request(MediaType.APPLICATION_JSON).post(Entity.entity(jsonInString, MediaType.APPLICATION_JSON));

        System.out.println("Response" + resp);
    }



    public static void main(String args[]) throws Exception {
        String account = "storageacctname";
        String key = "storageaccountkey";

        Client client = ClientBuilder.newClient();
        WebTarget target = client.target("https://" + account + ".table.core.windows.net/mytable");
        signRequestSK(target, account, key,client);

    }
}

Я ожидаю, что моей программе нужно вставить сущность в мою таблицу хранения.

1 Ответ

0 голосов
/ 10 апреля 2019

ramesh. Два формата для авторизации ToSign немного отличаются.

Авторизация общего ключа:

enter image description here

Разрешение Shared Key Lite:

enter image description here

Вы смешали их, чтобы использовать, что является неправильным. Пожалуйста, обратитесь к моему рабочему коду, как показано ниже (я использовал Shared Key Lite авторизацию): 

package rest;

import com.sun.org.apache.xml.internal.security.utils.Base64;
import org.json.JSONObject;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.TimeZone;

public class InsertTableEntityTest {

    private static final String account = "***";
    private static final String key = "***";

    public static void main(String args[]) throws Exception {

        String urlString = "https://" + account + ".table.core.windows.net/jay";
        System.out.println(urlString);

        //prepare for the json body
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("PartitionKey", "mypartitionkey");
        jsonObject.put("RowKey", "myrowkey");

        String jsonStr = jsonObject.toString();
        String encoding = "UTF-8";
        System.out.println(jsonStr);
        byte[] data = jsonStr.getBytes(encoding);

        HttpURLConnection conn = (HttpURLConnection) (new URL(urlString)).openConnection();
        conn.setDoInput(true);
        conn.setDoOutput(true);
        getFileRequest(conn, account, data);
        OutputStream outStream = conn.getOutputStream();

        outStream.write(data);
        outStream.flush();
        outStream.close();
        System.out.println(conn.getResponseCode());
        System.out.println(conn.getResponseMessage());

        BufferedReader br = null;
        if (conn.getResponseCode() != 200) {
            br = new BufferedReader(new InputStreamReader((conn.getErrorStream())));
        } else {
            br = new BufferedReader(new InputStreamReader((conn.getInputStream())));
        }
        System.out.println("Response body : " + br.readLine());
    }

    public static void getFileRequest(HttpURLConnection request, String account, byte[] data) throws Exception {
        SimpleDateFormat fmt = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss");
        fmt.setTimeZone(TimeZone.getTimeZone("GMT"));
        String date = fmt.format(Calendar.getInstance().getTime()) + " GMT";

        String stringToSign = date + "\n" +
                "/" + account + request.getURL().getPath();

        System.out.println("stringToSign : " + stringToSign);
        String auth = getAuthenticationString(stringToSign);
        System.out.println(auth);
        request.setRequestMethod("POST");
        request.setRequestProperty("x-ms-date", date);
        request.setRequestProperty("x-ms-version", "2013-08-15");
        request.setRequestProperty("Authorization", auth);
        request.setRequestProperty("Content-Length", String.valueOf(data.length));
        request.setRequestProperty("Content-Type", "application/json");
        request.setRequestProperty("Accept", "application/json");
    }

    private static String getAuthenticationString(String stringToSign) throws Exception {
        Mac mac = Mac.getInstance("HmacSHA256");
        mac.init(new SecretKeySpec(Base64.decode(key), "HmacSHA256"));
        String authKey = Base64.encode(mac.doFinal(stringToSign.getBytes("UTF-8")));
//        String auth = "SharedKey " + account + ":" + authKey;
        String auth = "SharedKeyLite  " + account + ":" + authKey;
        return auth;
    }
}

Вставить результат:

enter image description here

Кстати, x-ms-версия не является обязательной (последняя версия 2018-03-28 ) для поддержки этого формата. См. формат Json в табличном сервисе .

...