Enabling Grids for E-sciencE www.eu-egee.org Архитектура и основные сервисы gLite (проект EGEE) Н. Клопов (Петербургский Институт Ядерной Физики РАН) - презентация

1 Enabling Grids for E-sciencE Архитектура и основные сервисы gLite (проект EGEE) Н. Клопов (Петербургский Институт Ядерной Физики РАН)

2 Enabling Grids for E-sciencE 2 Что такое middleware gLite? Middleware – в контексте Grid, это специфическое программное обеспечение, использующееся для функционирования распределенной компьютерной сети. gLite: очередное поколение промежуточного программного обеспечения (ППО) проекта EGEE Исходно EGEE использовал ППО своего предшественника - проекта EDG (Еuropean Data Grid). Это ППО затем было развито в пакет LCG, и именно LCG работал в инфраструктуре EGEE на ранней стадии проекта. Параллельно в EGEE были выполнены работы по модернизации большей части исходного пакета, и был создан новый продукт – gLite, который сейчас устанавливается в инфраструктуру

3 Enabling Grids for E-sciencE 3 Принципы архитектуры gLite EGEE middleware is supposed to be developed following Service Oriented Architecture (SOA ) model. A service is a function which is well- defined, self-contained and does not depend on the context or state of other services. The services communicate with each other through well-defined interfaces and protocols (data passing or coordination of activities) Based on WEB service application that exposes its features using standard Internet protocol. WEB services interact by exchanging messages using Simple Object Access Protocol (SOAP) standard. Web Service Definition Language (WSDL) is used to specify the interface a service exposes.

4 Enabling Grids for E-sciencE 4 Service Oriented Architecture Service Oriented Architecture(SOA) определяет, как несколько независимых, распределенных процессов должны взаимодействовать при выполнении общей задачи (CORBA, DCOM).

5 Enabling Grids for E-sciencE 5 A Web Services Architecture Service Discovery Service RequestorService Provider Interface Web Services Description Language (WSDL) Определяет как использовать Сервис Publish WSDL Transport Simple Object Access Protocol (SOAP) Протокол RPC, основанный на обмене XML-документами Bind SOAP Registry Universal Description, Discovery and Integration (UDDI) Позволяет определить адрес сервиса с требуемой функциональностью ("Yellow Pages") Find UDDI Веб-сервис – программная система, идентифицируемая URI, интерфейс внешнего доступа которой and bindings описываются при помощи WDSL. Другие программные системы могут обнаруживать и взаимодействовать с Веб-сервисами в соответствии с их описанием на основе использования XML-сообщений посредством протокола SOAP.

6 Enabling Grids for E-sciencE 6 Пример запроса ReplicaManager::getAccessCost (LFN[], CE)

7 Enabling Grids for E-sciencE 7 Пример ответа Return message:

8 Enabling Grids for E-sciencE 8 Основные сервисы gLite Основные группы сервисов

9 Enabling Grids for E-sciencE 9 GSI-grid security infrastructure Три основных аспекта безопасности: Privacy – Обмен сообщениями должен быть приватным. (доступность передаваемых данных только участникам диалога) Integrity – Целостность данных, т.е. неизменность передаваемых данных Authentication – Идентификация сторон, участвующих в диалоге (проверка подлинности сущности)

10 Enabling Grids for E-sciencE 10 Алгоритмы шифрования Симметричный алгоритмНесимметричный алгоритм Шифротекст ШифрованиеРасшифровка Исходные данные Ключ (secret) Исходные данные Шифротекст ШифрованиеРасшифровка Исходные данные Открытый ключ Закрытый ключ

11 Enabling Grids for E-sciencE 11 Privacy in public-key cryptography

12 Enabling Grids for E-sciencE 12 Integrity in public-key systems Digital signatures (Цифровая подпись)

13 Enabling Grids for E-sciencE 13 Authentication Certificates and certificate authorities digital certificate – цифровой документ, подтверждающтй, что данный public key пренадлежит конкретному пользователю (системе, сервису). Этот документ подписан 3-й стороной, называемой certificate authority (CA). Доверие сертификату строится на доверии третьей стороне, подписавшей этот сертификат

14 Enabling Grids for E-sciencE 14 X.509 сертификаты

15 Enabling Grids for E-sciencE 15 Challenge-response authentication Алиса (А) хочет аутентифицировать Боба (Б). Б посылает свой сертификат Алисе, она проверяет правильность сертификата и подпись (имеет РК CA). А посылает Бобу произвольную фразу (challenge) с просьбой зашифровать её закрытым ключом Боба. Б шифрует пришедшие данные и отсылает ответ (response) Алисе. А расшифровывает ответ Боба с помощью переданного ранее открытого ключа и сравнивает результат с эталонной фразой. Если сравнение успешно, то Боб действительно владеет закрытым ключом, сответствующим сертификату.

16 Enabling Grids for E-sciencE 16 proxy-сертификат Проблемы: Single sign-on Delegation Proxy-certificate Применение proxy-сертификата для аутентификации избавляет пользователя от необходимости вводить свой пароль при каждом взаимодействии с сервисами. Mожно передавать свои proxy-cертификаты другим субъектам для выполнения операций от своего имени. Ограниченное время действия однократное предъявление первичного закрытого ключа User certificate file Private Key (Encrypted) Pass Phrase User Proxy certificate file

17 Enabling Grids for E-sciencE 17 proxy-сертификат voms-proxy-init –voms picard voms-proxy-info --all subject : /C=RU/O=RDIG/OU=users/OU=pnpi.nw.ru/CN=Nikolai Klopov/CN=proxy issuer : /C=RU/O=RDIG/OU=users/OU=pnpi.nw.ru/CN=Nikolai Klopov identity : /C=RU/O=RDIG/OU=users/OU=pnpi.nw.ru/CN=Nikolai Klopov type : proxy strength : 512 bits path : /tmp/x509up_u6901 timeleft : 11:59:43 === VO picard extension information === VO : picard subject : /C=RU/O=RDIG/OU=users/OU=pnpi.nw.ru/CN=Nikolai Klopov issuer : /C=IT/O=INFN/OU=Host/L=CNAF/CN=cert-voms-01.cnaf.infn.it attribute : /picard/Role=NULL/Capability=NULL

18 Enabling Grids for E-sciencE 18 Renewal Architecture

19 Enabling Grids for E-sciencE 19 Authorization Каждый Grid ресурс должен определить действия, которые может выполнять пользователь. -Database server: read/write/create permission? - Compute element: permission to execute? -Storage Element: write/read access? Обычно выполняется через grid-mapfiles:... "/C=CH/O=CERN/OU=GRID/CN=Simone Campana 7461".dteam "/C=CH/O=CERN/OU=GRID/CN=Andrea Sciaba 8968".cms "/C=CH/O=CERN/OU=GRID/CN=Patricia Mendez Lorenzo-ALICE".alice... Много пользователей и привелегий -> трудно администрировать! Пользователи объединяются в Виртуальные Организации (VO). трудно администрировать! Пользователи объединяются в Виртуальные Организации (VO).">

20 Enabling Grids for E-sciencE 20 Виртуальные организации «Динамическое собрание одиночек и организаций, гибко, безопастно и координировано разделяющее ресурсы» -- LCG-2 User Guide. VO с технической точки зрения: LDAP или HTTP или VOMS ресурс, перечисляющий Distinguished Names сертификатов пользователей конкретной VO. LCG-2: файл /etc/grid-security/grid-mapfile, один сертификат – одна виртуальная организация, нет разделения пользовательских ролей внутри VO. VOMS: призвана для управления ролью пользователя внутри VO и создания пользовательских групп. Вместо использования LDAP/HTTP для отображения пользователей будет использоваться VOMS-запросы. Внутренняя структура хранилища – Relational Database.

21 Enabling Grids for E-sciencE 21 Example VOMS presents a user's VO membership information as an extension to their X509 proxy certicate. GROUP: {string that names the group} ROLE: {string that gives the user role(s) in this group} CAP: {special capabilities assigned to this role} Example: A user works on ATLAS high energy physics experiment GROUP ROLE Special CAPability ATLAS user none ATLAS CAL user none ATLAS LARG update 10G disk space ATLAS FCAL administrator full write privileges

22 Enabling Grids for E-sciencE 22 Data management Гетерогенность –Данные хранятся на различных устройствах (диски, ленты), использующих различные методы доступа Распределенность –Данные хранятся на различных сайтах, где отсутствует общая разделяемая файловая система –Данные могут перемещаться между различными сайтами Различные административные домены –Данные храняться там, куда обычный доступ вам запрещен –Необходим общий интерфейс к устройствам Storage Resource Manager (SRM) –Необходим способ определения местоположения файлов File and Replica Catalogs –Необходима управляемая, надежная передача файлов File transfer and placement services –Необходима общая модель безопасности ACLs enforcement based on Grid identities – DNs

23 Enabling Grids for E-sciencE 23 Data Management Services Storage Element – common interface to storage – Storage Resource Manager Castor, dCache, DPM, … – POSIX-I/O gLite-I/O, rfio, dcap, xrootd – Access protocols gsiftp, https, rfio, … Catalogs – keep track where data is stored – File Catalog gLite File and Replica Catalog – Replica Catalog – File Authorization Service – Metadata Catalog Application specific catalogs File Transfer – scheduled reliable file transfer – Data Scheduler – File Transfer Service gLite FTS and glite-url- copy; – File Placement Service gLite FPS (FTS and catalog interaction)

24 Enabling Grids for E-sciencE 24 Storage Resource Management Данные хранятся на disk pool servers или Mass Storage Systems Управление этими ресурсами должно обеспечивать: – Прозрачный доступ к файлам (migration to/from disk pool) – Выделение места для файлов (Space reservation) – Управление временем жизни файлов (Life time management) – …. SRM (Storage Resource Manager) сервис реализует все эти требования: – SRM is a Grid Service that takes care of local storage interaction and provides a Grid interaface to outside world Interactions with the SRM is typically hidden by higher level services

25 Enabling Grids for E-sciencE 25 File Naming problem Имена файлов на SE имеют только локальное значение: – / tmp/picard/file1 (Unix) – srm://castorgrid.cern.ch:8443/srm/managerv1?SFN =/castor/cern.ch/file1 (SRM Site URL – SURL) Локальная система может преобразовывать имена файлов, напр. SURL не может использоваться прямо, он должен быть преобразован SRM в Transfer URL (TURL) : gsiftp://se05.cern.ch/scratch/file05 Для доступа к файлам необходим подход, позволяющий абстрагироваться от локальной системы имен и обеспечить общий для GRID среды механизм имен файлов

26 Enabling Grids for E-sciencE 26 Data Naming /knv/dput3.txt ee-3e18-137c-849a-c beef srm://lxb2086.cern.ch:8443/srm/managerV1? SFN=/dpm/cern.ch/home/picard/gm/knv/dput3.txt

27 Enabling Grids for E-sciencE 27 Каталоги данных Позволяет определить, где размещены файлы в Grid Может определить дополнительную семантику на LFN (атрибуты, ACLs,..) Позволяет определить местоположение реплик Central Catalog StorageIndex Metadata Catalog LFN Metadata Local Catalog Site A GUIDSURL LFN Local Catalog Site B GUIDSURL LFN GUID SE ID/ SURL MD PLANNED

28 Enabling Grids for E-sciencE 28 Каталоги данных File Catalog Metadata Catalog LFN Meta data Replica Catalog Site A GUIDSURL LFN Replica Catalog Site B GUIDSURL LFN GUID Site ID Позволяет определить, где размещены файлы в Grid Может определить дополнительную семантику на LFN (атрибуты, ACLs,..) Позволяет определить местоположение реплик

29 Enabling Grids for E-sciencE 29 gLite I/O glite-get glite-put glite-rm FiReMan Commands glite-catalog-ls glite-catalog-stat glite-catalog-mkdir glite-catalog-rmdir glite-catalog-mv glite-catalog-symlink glite-catalog-create glite-catalog-rm glite-catalog-setreplica glite-catalog-getreplica glite-catalog-chmod glite-catalog-getacl glite-catalog-setacl p - allow to change the permissions d - delete the entry r - read the file w - write to the file l - list contents x - execute g - get the meta data of the file s - set the meta data of the file glite-catalog-getattr glite-catalog-setattr # LFN: /knv/dput4.txt # User: /C=RU/O=RDIG/OU=users/OU=pnpi.nw.ru/CN=Nikolai Klopov # Group: egee-group # Base perms: user pdrwl-gs, group --r-l-g-, other

30 Enabling Grids for E-sciencE 30 File Access Overview Клиент использует API library или Command Line Interface –GUID или LFN может использоваться, напр. open(/grid/myFile) GSI Delegation to gLite I/O Server Сервер выполняет все операции от имени клиента –Преобразование LFN/GUID в SURL и TURL Встроенные операции: –Взаимодеиствие с каталогом –Взаимодеиствие с SRM –Native I/O FiReMan SRM rfio dcap gsiftp Server Client open(LFN) Catalog Modules Protocol Modules SRM API MSS aio LFN – GUID – SURL mappings SURL - TURL mappings

31 Enabling Grids for E-sciencE 31 DM Interaction Overview File and Replica Catalog StorageIndex Fireman Database WMS Storage Element SRM Storage gLite I/OgridFTP File Transfer and Placement Service FTS FPS Transfer Agent Database VOMS MyProxy Get credential Store credential File I/O File namespace and Metadata mgmt File replication Proxy renewalReplica Location WSDL API

32 Enabling Grids for E-sciencE 32 gLite FTS/FPS File Transfer/Placement Service (FTS,FPS) –База данных заданий на передачу файлов –Предоставляет Transfer Web Service интерфейс для клиента (submit, cancel, status) –Имеет Web Interface –Mодифицирует Catalog если необходимо Transfer Agent –Основные действия Получает задания из Transfer Job Database Управляет передачей через множество каналов Moниторирует статус и модифицирует Transfer Job Database Transfer Service (glite-url-copy) –Фактически выполняет передачу: SRM – SRM, gsiftp – SRM, gsiftp – gsiftp –Moниторирование Job DB FTS/FPS WebService Transfer Agent Actions Channel glite-url-copy Web Monitor

33 Enabling Grids for E-sciencE 33 FTS/FPS File Transfer Service (FTS) –Действует только через SRM SURLs or gsiftp URLs – submit(source-SURL, destination-SURL) File Placement Service (FPS) –Позволяет работать с LFNs –Взаимодействует с replica catalogs –Регистрирует реплики в каталоге реплик – submit(transferJobs) (transferJob = sourceLFN, destinationSE) Job DB FTS WebService FPS plugin Catalog

34 Enabling Grids for E-sciencE 34 Информационная Система gLite В распределенной среде важна возможность получать информацию о доступных в данный момент ресурсах. Эта информация может включать: - сайты (CE), способные выполнить данное задание, их загрузка, ПО, установленное на них. - сайты, предоставляющие возможности для хранения данных, включая их статус, максимальный размер и число файлов, которые могут быть сохранены. - данные мониторирования процесса выполнения задания

35 Enabling Grids for E-sciencE 35 Uses of the IS in EGEE/LCG If you are a middleware developer Workload Management System: Matching job requirements and Grid resources Monitoring Services: Retrieving information of Grid Resources status and availability If you are a user Retrieve information of Grid resources and status Get the information of your jobs status If you are site manager or service You generate the information for example relative to your site or to a given service

36 Enabling Grids for E-sciencE 36 Information and Monitoring LCG-2 currently uses GT Monitoring and Discovery Service (MDS) architecture together with Berkley Database Information Indexes (BDII) The information system is built on LDAP Light-weight Directory Access Protocol A Schema describes the attributes and the types of the attributes associated with data objects Example: GlueSiteInfo dataGridVersion: LCG-2_0_0 installationDate: Z objectClass: SiteInfo siteName: nikhef.nl siteSecurityContact: sysAdminContact: userSupportContact:

37 Enabling Grids for E-sciencE 37 Элементы Информационной Системы Основные шаги: 1. На каждом сайте providers передают статическую и динамическую информацию о своем состоянии на servers 2. central system опрашивает эти сервера и сохраняет полученные данные 3. Эта информация доступна через заданный access protocol 4. Центральная система предоставляет информацию в соответствии со schema, которая определяет стандарт на описание сетевых ресурсов BDII является текущей EGEE/LCG Информационной Системой и основывается на LDAP

38 Enabling Grids for E-sciencE 38 Модель данных Иерархическая – структура типа дерево; потомок имеет только одного родителя. легко разделяется (partitions); легко отображается на физические устройства. BDII, LDAP Реляционная – набор таблиц; Язык запросов (SQL) эффективный, широко распостраненный R-GMA

39 Enabling Grids for E-sciencE 39 LCG IS -- Иерархическая модель предоставления данных в информационной системе: CE, SE GRIS GIIS BDII (GIIS в настоящее время заменяется на BDII) -- Ресурсы описываются при помощ и GLUE Schema.

40 Enabling Grids for E-sciencE 40 Information Providers network information between this and other sites CE storage elements that are close (not necessarily at the same site) status supported protocols file statistics SE site information site DIT

41 Enabling Grids for E-sciencE 41 Some examples of the Glue Schema (I) Attributes for the CE ¤ Base Class for the CE information (objectclass: GlueCETop ) : No attributes ¤ CE ( objectclass: GlueCE ) GlueCEUniqueID : unique identifier for the CE GlueCEName: human-readable name of the service ¤ CE Status ( objectclass: GlueCEState ) GlueCEStateRunningJobs: number of running jobs GlueCEStateWaitingJobs: number of jobs not running GlueCEStateTotalJobs: total number of jobs (running + waiting) GlueCEStateStatus: queue status: queueing (jobs accepted but not running), production (jobs accepted and run), closed (neither accepted nor run), draining (jobs not accepted but those already queued are running) GlueCEStateWorstResponseTime: worst possible time between the submission of the job and the start of its execution

42 Enabling Grids for E-sciencE 42 Some examples of the Glue Schema (II) 3. Attributes for the SE ¤ Base Class ( objectclass: GlueSETop ) : No attributes ¤ Architecture ( objectclass: GlueSLArchitecture ) GlueSLArchitectureType : type of storage hardware (disk, tape, etc) ¤ Storage Service Access Protocol ( objectclass: GlueSEAccessProtocol ) GlueSEAccessProtocolType: protocol type to access or transfer files GlueSEAccessProtocolPort: port number for the protocol GlueSEAccessProtocolVersion: protocol version GlueSEAccessProtocolAccessTime: time to access a file using this protocol 4. Mixed Attributes ¤ Association between one CE and one or more SEs ( objectclass: GlueCESEBindGroup ) GlueCESEBindGroupCEUniqueID : unique ID for the CE GlueCESEBindGroupSEUniqueID : unique ID for the SE

43 Enabling Grids for E-sciencE 43 R-GMA LDAP не поддерживает агрегатные запросы на различные объекты, т.е. запрос основывается на атрибутах объекта. R-GMA: Relation Grid Monitoring Archicecture Использует реляционную модель данных. –Данные представляются в виде таблиц. –Структура данных определяется по колонкам. –Каждая запись есть строка (tuple). –Язык запросов - Structured Query Language (SQL). Поддерживает различные типы запросов: - streams - archives - lates-value

44 Enabling Grids for E-sciencE 44 Архитектура R-GMA Все Producers регистрируются в Registry, определяя Schema Consumer получает из Registry те URLs, которые могут выполнить его запрос. Consumer взаимодействует с этими Producers. Producers обрабатывают query и возвращают tuples Consumer. Consumer Producer 1 Registry TableName Value 1Value2 Value 3Value 4 TableName Value 1Value 2 TableNameURL 1 TableNameURL 2 Producer 2 TableName Value 3Value 4 Schema Виртуальная база данных

45 Enabling Grids for E-sciencE 45 Mediator Queries posed against a virtual data base The Mediator must: -find the right Producers -combine information from them Hidden component – but vital to R-GMA Will eventually support full distributed queries but for now will only merge information from multiple producers for queries on one table or over multiple tables from one producer

46 Enabling Grids for E-sciencE 46 Information and Monitoring

47 Enabling Grids for E-sciencE 47 Information and Monitoring Service URIVOtype Contactsite ServiceStatus URIVOtypeupstatus gppse01aliceSEySE is running gppse01atlasSEySE is running gppse02cmsSEnSE ERROR 101 lxshare0404aliceSEySE is running lxshare0404atlasSEySE is running Result Set (Consumer) URI Contact SELECT Service.URI Service. Contact FROM Service S, ServiceStatus SS WHERE (S.URI= SS.URI and SS.up=n)

48 Enabling Grids for E-sciencE 48 R-GMA: Producers Primary Producer user code периодически inserts tuples в storage, который поддерживается Primary Producer service. Рroducer service автономно отвечает на запросы consumer. Secondary Producer Тuples запрашиваются от другого producer. On-demand Producer Нет внутреннего хранилища, Данные выдаются User Code в ответ на запрос

49 Enabling Grids for E-sciencE 49 R-GMA: Consumer

50 Enabling Grids for E-sciencE 50 R-GMA in Accounting

51 Enabling Grids for E-sciencE 51

52 Enabling Grids for E-sciencE 52 Job Management Services Сервисы управления заданиями (Job Management Services ) computing element job management (запуск и управление заданиями) Информирование о своих характеристиках и статусе workload management управление запуском заданий accounting ocomputing, storage and network resources job provenance Сохранение данных о запущенных заданиях, условий выполнения и окружения и т.п. На длительный период времени odebugging, post-mortem analysis, comparison of job execution package manager automates the process of installing, upgrading, configuring, and removing software packages from a shared area on a grid site. oextension of a traditional package management system to a Grid

53 Enabling Grids for E-sciencE 53 WMS Services UI Replica Catalog Inform. System Storage Element Resource Broker Node (Workload Manager, WM) WMS Architecture Overview Logging & Bookkeeping Job status Grid Interface Computing Element LRMS Match Maker Task Queue Information Supermarket Network Server Job Submission gLite

54 Enabling Grids for E-sciencE 54 WMSs Scheduling Policies Eager scheduling (push mode) Lazy scheduling (pool mode)

55 Enabling Grids for E-sciencE 55 The Information Supermarket ISM represents one of the most notable improvements in the WM as inherited from the EU DataGrid (EDG) project –decoupling between the collection of information concerning resources and its use allows flexible application of different policies The ISM basically consists of a repository of resource information that is available in read only mode to the matchmaking engine –the update is the result of the arrival of notifications active polling of resources some arbitrary combination of both –can be configured so that certain notifications can trigger the matchmaking engine improve the modularity of the software support the implementation of lazy scheduling policies

56 Enabling Grids for E-sciencE 56 The Task Queue –Возможность сохранения запроса на запуск задания, если отсутствуют ресурсы, удовлетворяющие заданным требованиям (Non-matching requests) Non-matching requests –будут выбираться из очереди или периодически eager scheduling –Или как только нотификация о доступности ресурса появится в ISM lazy scheduling

57 Enabling Grids for E-sciencE 57 Logging & Bookkeeping

58 Enabling Grids for E-sciencE 58 Job Submission Services WMS components handling the job during its lifetime and performing the submission Job Adapter –is responsible for making the final touches to the JDL expression for a job, before it is passed to CondorC for the actual submission creating the job wrapper script that creates the appropriate execution environment in the CE worker node transfer of the input and of the output sandboxes CondorC –responsible for performing the actual job management operations job submission, job removal DAGMan –meta-scheduler purpose is to navigate the graph determine which nodes are free of dependencies follow the execution of the corresponding jobs. Log Monitor –is responsible for watching the CondorC log file intercepting interesting events concerning active jobs events affecting the job state machine triggering appropriate actions.

59 Enabling Grids for E-sciencE 59 Job Description Language (JDL Поддерживаемые атрибуты можно разделить на 2 категории: Атрибуты задания (Job Attributes) Определяют само задание Ресурсы Используются Workload Manager для matchmaking algorithm (выбрать наилучший ресурс для запуска задания) Computing Resource Используются для определения Requirements и Rank attributes Data and Storage resources Input data, Storage Element (SE), где сохранять выходные данные, протоколы доступа к SE

60 Enabling Grids for E-sciencE 60 Example of JDL File [ JobType=Normal; Executable = gridTest; StdError = stderr.log; StdOutput = stdout.log; InputSandbox = {/home/mydir/test/gridTest}; OutputSandbox = {stderr.log, stdout.log}; InputData = {lfn:/glite/myvo/mylfn }; DataAccessProtocol = gridftp; Requirements = other.GlueHostOperatingSystemNameOpSys == LINUX && other.GlueCEStateFreeCPUs>=4; Rank = other.GlueCEPolicyMaxCPUTime; ]

61 Enabling Grids for E-sciencE 61 Job Resubmission If something goes wrong, the WMS tries to reschedule and resubmit the job (possibly on a different resource satisfying all the requirements) Maximum number of resubmissions: min(RetryCount, MaxRetryCount) RetryCount: JDL attribute MaxRetryCount: attribute in the RB configuration file

62 Enabling Grids for E-sciencE 62 Computing Element Service representing a computing resource Main functionality: job management –Run jobs –Cancel jobs –Suspend and resume jobs –Provide info on quality of service How many resources match the job requirements ? What is the estimated time to have the job starting its execution ? … –… Used by the WM or by any other client (e.g. end-user) CE architecture accommodated to support both push and pull model –Push model: the job is pushed to the CE by the WM –Pull model: the CE asks the WM for jobs These two models are somewhat mirrored in the resource information flow –In order to 'pull' a job a resource must choose where to 'push' information about itself

63 Enabling Grids for E-sciencE 63 CE Architecture CE LSF Worker Nodes PBS? Mon Client WEB JobSubmit JobAssess JobKill JobSuspend JobResume JobGetStatus Web service accepting job management requests

64 Enabling Grids for E-sciencE 64 CE Architecture CE LSF Worker Nodes PBS? Mon Client WEB Notifications Job requests Async. notifications about job/CE events Job requests (for CE working in pull mode )

65 Enabling Grids for E-sciencE 65 Типы заданий Normal DAG - Directed Acyclic Graphs (DAG) MPICH - Message Passing Interface Checkpointable Jobs Partitionable Interactive Jobs Collection Parametric

66 Enabling Grids for E-sciencE 66 Directed Acyclic Graphs (DAGs) A DAG represents a set of jobs: Nodes = Jobs Edges = Dependencies NodeA NodeB NodeC NodeD NodeE

67 Enabling Grids for E-sciencE 67 Message Passing Interface (MPI) The MPI job is run in parallel on several processors. Libraries supported for parallel jobs: MPICH. Currently, execution of parallel jobs is supported only on single CEs. MPI JOB CE WN

68 Enabling Grids for E-sciencE 68 MPI: JDL Structure Type = job; JobType = MPICH; Executable = …; NodeNumber = int > 1; Argument = …; Requirements = Member(MpiCH, other.GlueHostApplicationSoftwareRunTimeEnvironment) && other.GlueCEInfoTotalCPUs >= NodeNumber ; Rank = other.GlueCEStateFreeCPUs; Mandatory Optional Mandatory

69 Enabling Grids for E-sciencE 69 Logical Checkpointable Jobs It is a job that can be decomposed in several steps; In every step the job state can be saved in the LB and retrieved later in case of failures; The job can start running from a previously saved state instead from the beginning again. STEP 1STEP 2STEP 3STEP 4 JOBS START JOBS END A BCD

70 Enabling Grids for E-sciencE 70 Checkpointable Jobs: JDL Structure Type = job; JobType = checkpointable; Executable = …; JobSteps = list int | list string; CurrentStep = int > = 0; Argument = …; Requirements = …; Rank = ; Mandatory Optional

71 Enabling Grids for E-sciencE 71 Interactive Jobs JobType = Interactive When an interactive job is executed, a window for the stdin, stdout, stderr streams is opened Possibility to send the stdin to the job Possibility the have the stderr and stdout of the job when it is running

72 Enabling Grids for E-sciencE 72 Partitionable jobs JobType=Partitionable JobSteps = {"cms0", "cms1", "cms2", "cms3", "orca"}; StepWeight = {7.5, 25, 37.5, 15, 15}; CurrentStep = 0;

73 Enabling Grids for E-sciencE 73 Parametric jobs JobType = "Parametric"; Executable = "cms_sim.exe"; StdInput = "input_PARAM_.txt"; StdOutput = "myoutput_PARAM_.txt"; StdError = "myerror_PARAM_.txt"; Parameters = 10000; ParameterStart = 1000; ParameterStep = 10; InputSandbox = { "file:///home/cms/cms_sim.exe", "file:///home/cms/data/input_PARAM_.txt " }; OutputSandbox = { "myoutput_PARAM_.txt", "myerror_PARAM_.txt" }; Requirements = other.GlueCEInfoTotalCPUs > 2; Rank = other.GlueCEStateFreeCPUs; 2; Rank = other.GlueCEStateFreeCPUs;">