Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.


Info
titleUwaga!

Ze względu na wycofwanie usługi Cloud 2.0, platforma HyperFlow jest dostępna w formie właściwej aplikacji dostępnej w repozytorium: https://github.com/hyperflow-wms która może zostać uruchomiona w ramach Cloudu 3.0 lub dowolnego z klastrów obliczeniowych. Repozytorium kodu zawiera obcenie dostępne skrypty, wspomagające automatyzację uruchomienia platformy HyperFlow.

Krótki opis usługi

Platforma HyperFlow jest usługą przeznaczoną zarówno dla zaawansowanych deweloperów jak i naukowców dziedzinowych, pracujących nad rozwojem aplikacji reprezentowanych przez workflowy. Gotowe workflowy korzystające z platformy mogą być wykorzystywane przez zwykłego użytkownika infrastruktury PLGrid.

...

Należy utworzyć w swoim katalogu domowym plik 'workflow.json' o następującej zawartości:

...



{
    "name": "hello_task",
    "processes": [ {
        "name": "process",
        "type": "dataflow",
        "function": "amqpCommand",
        "config" : {
            "executor" : {
                "executable": "/bin/cat",
                "args": "input.txt > output.txt",
                "options": {
                    "prefix": "gsiftp://zeus.cyfronet.pl/people/plglogin"
                }
            }
        },
        "ins":  [ 0 ],
        "outs": [ 1 ]
    } ],
    "signals": [ {
        "name": "input.txt",
        "data": "1"
    }, {
        "name": "output.txt"
    } ],
    "ins":  [ 0 ],
    "outs": [ 1 ]
}

 


lub pobrać gotowy plik:

workflow.json

Przygotowanie pliku wejściowego:


 

[plglogin@zeus ~]$ echo "input" > input.txt

 


Setup środowiska:

...


[plglogin@zeus ~]$ module load plgrid/tools/hflowclient

 


[plglogin@zeus ~]$ grid-proxy-init
(...)
[plglogin@zeus ~]$ hflowc setup
Appliance set hfworkflow created successfully!
WfMain created successfully!
waiting for wfMain to start..............wfMain is active!
Found port mapping 1032->443, hfmain endoint: http://149.156.11.4:1032
starting wfworker_0
Workers created
 


Notujemy "hfmain endpoint", po zakończeniu wykonania polecenia należy odczekać jeszcze 1-2 minuty aby wszystkie usługi się podniosły. W miedzyczasie możemy obserwować tworzenie się maszyn w interfejsie webowym cloudu, dostępnym pod adresem: https://cloud.plgrid.pl w zakładce "Workflows". Na tym etapie, w cloudzie powstało środowisko uruchomieniowe.

Uruchomienie workflowu:


 

[plglogin@zeus ~]$ hflowc runwf http://149.156.11.4:1032 workflow.json

W tym momencie workflow zostanie przesłany do maszyny zawierającej silnik HyperFlow i uruchomiony. Wynikiem działania workflowu będą informacje znajdujące się w pliku wyjściowym.

Sprawdzenie wyników:

 


W następujący sposób sprawdzamy zawartość pliku wynikowego, który został stworzony na "workerze" w trakcie wykonania workflowu a następnie skopiowany jako "output" do katalogu zdefiniowanego w workflole.


 


[plglogin@zeus ~]$ cat output.txt
hello world


Warning



 

Usunięcie środowiska uruchomieniowego workflow:

...

Podczas korzystania z klienta otrzymuję komunikat podobny do:

[Error: error getting appliance sets: 400, Bad Request]

 Należy się upewnić, że korzystamy z proxy od SimpleCA stworzonego za pomocą komendy grid-proxy-init lub voms-proxy-init -rfc lub proxy pobranego z PLGridowego OpenId (format: RFC 3820 compliant impersonation proxy).

...