Блог

Я использую MultipartObjectAssembler для загрузки данных из базы данных в хранилище объектов OCI. Есть ли способ узнать причину сбоя при использовании multipart upload?

Когда я пытаюсь зафиксировать ассемблер, я получаю исключение IllegalStateException с сообщением «Одна или несколько частей не были успешно загружены». Я хотел бы знать, почему какая-либо часть вышла из строя? Я не смог найти способ получить эту информацию из SDK.

 try {
    assembler.addPart(new ByteArrayInputStream(part, 0, length),
                    length,
                    null);

    assembler.commit();
} catch (Exception e) {
    assembler.abort();
    throw new RuntimeException(e.getMessage());
} 
  

Редактировать: мне нужно получить исключение, вызванное отказавшей частью, и распространить сообщение об ошибке.

Есть ли причина, по которой вы не используете UploadManager ? Он должен сделать все за вас, включая добавление частей и фиксацию. Вот сквозной пример: https://github.com/oracle/oci-java-sdk/blob/master/bmc-examples/src/main/java/UploadObjectExample.java

Если по какой-либо причине вы не можете использовать UploadManager , тем не менее, ознакомьтесь с его исходным кодом, поскольку он демонстрирует предполагаемое использование MultipartObjectAssembler : https://github.com/oracle/oci-java-sdk/blob/master/bmc-objectstorage/bmc-objectstorage-extensions/src/main/java/com/oracle/bmc/objectstorage/transfer/UploadManager.java#L175-L249

1. Вы создаете MultipartObjectAssembler :

 MultipartObjectAssembler assembler =
                createAssembler(request, uploadRequest, executorServiceToUse);
  

2. Вы создаете новый запрос. Это вернет вам a MultipartManifest , который позже позволит вам проверить, не вышли ли из строя части.

 manifest =
                    assembler.newRequest(
                            request.getContentType(),
                            request.getContentLanguage(),
                            request.getContentEncoding(),
                            request.getOpcMeta());
  

3. Затем вы добавляете все части:

                     assembler.addPart(
                            ProgressTrackingInputStreamFactory.create(
                                    chunk, progressTrackerFactory.getProgressTracker()),
                            chunk.length(),
                            null);
  

4. Затем вы фиксируете. Это то, где ваш код в настоящее время выдает. Я подозреваю, что добавлены не все части.

 CommitMultipartUploadResponse response = assembler.commit();
  

5. Если что-то пойдет не так, проверьте MultipartManifest.listCompletedParts() , MultipartManifest.listFailedParts() , и MultipartManifest.listInProgressParts() . В манифесте должно быть указано, какие части вышли из строя. К сожалению, не причина; для этого вы можете включить ERROR ведение журнала уровня для com.oracle.bmc.objectstorage.transfer ( com.oracle.bmc.objectstorage.transfer.internal.MultipartTransferManager в частности, для класса).

Если я что-то неправильно понял, пожалуйста, дайте мне знать. В этом случае больший и более полный фрагмент кода поможет мне в отладке. Спасибо!