From d8f7c33be71f7f0265312df3ab93ba009bdd83d8 Mon Sep 17 00:00:00 2001 From: Gianpaolo Coro Date: Mon, 1 Feb 2016 22:07:37 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@122704 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../executor/util/StorageUtils.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/main/java/org/gcube/dataanalysis/executor/util/StorageUtils.java b/src/main/java/org/gcube/dataanalysis/executor/util/StorageUtils.java index 06fb621..9ba268f 100644 --- a/src/main/java/org/gcube/dataanalysis/executor/util/StorageUtils.java +++ b/src/main/java/org/gcube/dataanalysis/executor/util/StorageUtils.java @@ -24,6 +24,7 @@ import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration; public class StorageUtils { + public static void downloadInputFile(String fileurl, String destinationFile) throws Exception{ downloadInputFile(fileurl, destinationFile, false); } @@ -52,6 +53,23 @@ public class StorageUtils { out.close(); } + public static String uploadFilesOnStorage(String scope, String user, String localFolder, String remoteFolder, String file) throws Exception { + try { + ScopeProvider.instance.set(scope); + AnalysisLogger.getLogger().info("Loading file on scope: " + scope); + IClient client = new StorageClient(AlgorithmConfiguration.StatisticalManagerClass, AlgorithmConfiguration.StatisticalManagerService, user, AccessType.SHARED, MemoryType.VOLATILE).getClient(); + String remotef = remoteFolder+file; + client.put(true).LFile(new File(localFolder,file).getAbsolutePath()).RFile(remotef); + String url = client.getUrl().RFile(remotef); + AnalysisLogger.getLogger().info("Loading finished"); + System.gc(); + return url; + } catch (Exception e) { + AnalysisLogger.getLogger().info("Error in uploading file: " + e.getLocalizedMessage()); + throw e; + } + } + public static String uploadFilesOnStorage(String scope, String user, String localFolder, String file) throws Exception { try { ScopeProvider.instance.set(scope);