Project

General

Profile

« Previous | Next » 

Revision 41150

Added missing profile

View differences:

modules/dnet-newpuma-workflows/trunk/src/main/resources/eu/dnetlib/msro/puma/workflows/applicationContext-nodes.properties
1
services.pumastore.mongodb.host  = localhost
2
services.pumastore.mongodb.port  = 27017
3
services.pumastore.mongodb.db    = pumaStore
4

  
5
dnet.dataload.datasource.mdstores.xquery = for $x in collection('/db/DRIVER/MDStoreDSResources/MDStoreDSResourceType')  where $x//METADATA_FORMAT="DMF"  return $x//RESOURCE_IDENTIFIER/@value/string()
6
services.transformation.vocabularyproperties.json = {"map":{"AccessRights":{"name":"dnet:access_modes", "caseSensitive":"false"}, "Languages":{"name":"dnet:languages", "caseSensitive":"false", "delimiter":"/"}, "TextTypologies":{"name":"pumatype", "caseSensitive":"false"}}}
modules/dnet-newpuma-workflows/trunk/src/main/resources/eu/dnetlib/msro/puma/workflows/applicationContext-nodes.xml
1
<?xml version="1.0" encoding="UTF-8"?>
2
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3
       xmlns:p="http://www.springframework.org/schema/p" xmlns="http://www.springframework.org/schema/beans"
4
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
5

  
6

  
7
	<!-- NODE SECTION -->
8
	<bean id="wfNodeFeedEnrichedRecords"
9
	      class="eu.dnetlib.msro.puma.nodes.FeedEnrichedRecordsJobNode"
10
	      scope="prototype"/>
11

  
12

  
13
	<bean id="wfNodeMDStoreDatasourceResolver"
14
	      class="eu.dnetlib.msro.puma.nodes.MDStoreDatasourceResolverJobNode"
15
	      scope="prototype"/>
16

  
17

  
18
	<bean id="wfNodeFetchRecordsToIndex"
19
	      class="eu.dnetlib.msro.puma.nodes.FetchRecordsToIndexJobNode"
20
	      scope="prototype"/>
21

  
22
	<bean id="wfNodeUpdatePUMAIndex"
23
	      class="eu.dnetlib.msro.puma.nodes.UpdatePUMAIndexJobNode"
24
	      p:layoutToRecordStylesheet="classpath:/eu/dnetlib/msro/workflows/xslt/layoutToRecordStylesheet.xsl"
25
	      p:xsltRSFactory-ref="xsltResultSetFactory"
26
	      p:processCountingResultSetFactory-ref="msroProcessCountingResultSetFactory"
27
	      p:defaultIndexId="${service.msro.index.defaultIndex}" scope="prototype"/>
28

  
29

  
30
	<bean id="pumaMongoServer" class="com.mongodb.Mongo">
31
		<constructor-arg index="0" type="com.mongodb.ServerAddress">
32
			<bean class="com.mongodb.ServerAddress">
33
				<constructor-arg index="0"
34
				                 value="${services.pumastore.mongodb.host}"/>
35
				<constructor-arg index="1"
36
				                 value="${services.pumastore.mongodb.port}"/>
37
			</bean>
38
		</constructor-arg>
39
	</bean>
40

  
41

  
42
	<bean id="pumaMongoDB" factory-bean="pumaMongoServer"
43
	      factory-method="getDB">
44
		<constructor-arg index="0"
45
		                 value="${services.pumastore.mongodb.db}"/>
46
	</bean>
47

  
48

  
49
	<bean id="PUMAObjectStore" class="eu.dnetlib.msro.puma.objectstore.PUMAObjectStore" p:db-ref="pumaMongoDB"/>
50

  
51

  
52
</beans>
modules/dnet-newpuma-profiles/trunk/src/main/resources/eu/dnetlib/test/profiles/workflows/FeedRecord/indexWF.xml
1
<?xml version="1.0" encoding="UTF-8"?>
2
<RESOURCE_PROFILE>
3
	<HEADER>
4
		<RESOURCE_IDENTIFIER
5
				value="83bbb3a4-b0a3-4f60-bf39-c518f6698eda_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl"/>
6
		<RESOURCE_TYPE value="WorkflowDSResourceType"/>
7
		<RESOURCE_KIND value="WorkflowDSResources"/>
8
		<RESOURCE_URI value=""/>
9
		<DATE_OF_CREATION value="2014-08-01T18:13:51.0Z"/>
10
	</HEADER>
11
	<BODY>
12
		<WORKFLOW_NAME>Index Records</WORKFLOW_NAME>
13
		<WORKFLOW_TYPE>Provision</WORKFLOW_TYPE>
14
		<WORKFLOW_PRIORITY>30</WORKFLOW_PRIORITY>
15
		<CONFIGURATION start="manual">
16
			<NODE name="findIndex" type="FindIndex" isStart="true">
17
				<DESCRIPTION/>
18
				<PARAMETERS>
19
					<PARAM name="mdFormat" type="string" managedBy="user" required="true">DMF</PARAM>
20
					<PARAM name="layout" type="string" managedBy="system" required="true">index</PARAM>
21
					<PARAM name="interpretation" type="string" managedBy="system" required="true">transformed</PARAM>
22
				</PARAMETERS>
23
				<ARCS>
24
					<ARC name="found" to="fetchRecord"/>
25
					<ARC name="notFound" to="prepare"/>
26
				</ARCS>
27
			</NODE>
28

  
29
			<NODE name="prepare" type="PrepareCreateIndex">
30
				<DESCRIPTION>Prepare create index</DESCRIPTION>
31
				<PARAMETERS>
32
					<PARAM managedBy="system" name="format" required="true" type="string">DMF</PARAM>
33
					<PARAM managedBy="system" name="interpretation" required="true" type="string">transformed</PARAM>
34
					<PARAM managedBy="system" name="layout" required="true" type="string">index</PARAM>
35
				</PARAMETERS>
36
				<ARCS>
37
					<ARC to="createIndex"/>
38
				</ARCS>
39
			</NODE>
40
			<NODE name="createIndex" type="CreateIndex">
41
				<DESCRIPTION>Create index</DESCRIPTION>
42
				<PARAMETERS>
43
					<PARAM managedBy="system" name="outputPrefix" required="true" type="string">index_</PARAM>
44
				</PARAMETERS>
45
				<ARCS>
46
					<ARC to="checkIndex"/>
47
				</ARCS>
48
			</NODE>
49

  
50
			<NODE name="checkIndex" type="FindIndex">
51
				<DESCRIPTION/>
52
				<PARAMETERS>
53
					<PARAM name="mdFormat" type="string" managedBy="user" required="true">DMF</PARAM>
54
					<PARAM name="layout" type="string" managedBy="system" required="true">index</PARAM>
55
					<PARAM name="interpretation" type="string" managedBy="system" required="true">transformed</PARAM>
56
				</PARAMETERS>
57
				<ARCS>
58
					<ARC name="found" to="fetchRecord"/>
59
					<ARC name="notFound" to="createIndex"/>
60
				</ARCS>
61
			</NODE>
62

  
63

  
64
			<NODE name="fetchRecord" type="FetchRecordsToIndex">
65
				<DESCRIPTION>Fetch records from PUMA STORE</DESCRIPTION>
66
				<PARAMETERS>
67
					<PARAM required="true" type="string" name="eprOutputParam" managedBy="system">index_epr</PARAM>
68
				</PARAMETERS>
69
				<ARCS>
70
					<ARC to="indexRecords"/>
71
				</ARCS>
72
			</NODE>
73

  
74
			<NODE name="indexRecords" type="UpdatePUMAIndex">
75
				<DESCRIPTION>Index records</DESCRIPTION>
76
				<PARAMETERS>
77
					<PARAM required="true" type="string" name="eprParam" managedBy="system">index_epr</PARAM>
78
					<PARAM required="true" type="string" name="feedingType" managedBy="system">REFRESH</PARAM>
79
					<PARAM required="true" type="boolean" name="emptyResult" managedBy="user">true</PARAM>
80
				</PARAMETERS>
81
				<ARCS>
82
					<ARC to="success"/>
83
				</ARCS>
84
			</NODE>
85

  
86
		</CONFIGURATION>
87
		<STATUS/>
88
	</BODY>
89
</RESOURCE_PROFILE>
90

  
91

  
modules/dnet-newpuma-profiles/trunk/src/main/resources/eu/dnetlib/test/profiles/workflows/FeedRecord/FeedRecordMetaWF.xml
1
<RESOURCE_PROFILE>
2
	<HEADER>
3
		<RESOURCE_IDENTIFIER value="b3e95edc-1815-4f19-a927-3e37e653f2d7_TWV0YVdvcmtmbG93RFNSZXNvdXJjZXMvTWV0YVdvcmtmbG93RFNSZXNvdXJjZVR5cGU="/>
4
		<RESOURCE_TYPE value="MetaWorkflowDSResourceType"/>
5
		<RESOURCE_KIND value="MetaWorkflowDSResources"/>
6
		<RESOURCE_URI value=""/>
7
		<DATE_OF_CREATION value="2015-02-25T18:09:02+01:00"/>
8
	</HEADER>
9
	<BODY>
10
		<METAWORKFLOW_NAME family="provision_profiles">Create Infospace</METAWORKFLOW_NAME>
11
		<METAWORKFLOW_DESCRIPTION/>
12
		<METAWORKFLOW_SECTION>InfoSpace Provision</METAWORKFLOW_SECTION>
13
		<ADMIN_EMAIL/>
14
		<CONFIGURATION status="EXECUTABLE">
15
			<WORKFLOW id="52e2cab6-bfbe-425e-bc1c-231d4c15137c_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl" name="Feed Records">
16
				<WORKFLOW id="83bbb3a4-b0a3-4f60-bf39-c518f6698eda_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl" name="Index Records"/>
17
			</WORKFLOW>
18
		</CONFIGURATION>
19
		<SCHEDULING enabled="false">
20
			<CRON>0 0 0 ? * *</CRON>
21
			<MININTERVAL>10080</MININTERVAL>
22
		</SCHEDULING>
23
	</BODY>
24
</RESOURCE_PROFILE>
modules/dnet-newpuma-profiles/trunk/src/main/resources/eu/dnetlib/test/profiles/workflows/FeedRecord/FeedRecordWF.xml
1
<?xml version="1.0" encoding="UTF-8"?>
2
<RESOURCE_PROFILE>
3
	<HEADER>
4
		<RESOURCE_IDENTIFIER value="52e2cab6-bfbe-425e-bc1c-231d4c15137c_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl"/>
5
		<RESOURCE_TYPE value="WorkflowDSResourceType"/>
6
		<RESOURCE_KIND value="WorkflowDSResources"/>
7
		<RESOURCE_URI value=""/>
8
		<DATE_OF_CREATION value="2014-08-01T18:13:51.0Z"/>
9
	</HEADER>
10
	<BODY>
11
		<WORKFLOW_NAME>Feed Records</WORKFLOW_NAME>
12
		<WORKFLOW_TYPE>Provision</WORKFLOW_TYPE>
13
		<WORKFLOW_PRIORITY>30</WORKFLOW_PRIORITY>
14
		<CONFIGURATION start="manual">
15
			<NODE name="findMDStores" type="MDStoreDatasourceResolver" isStart="true">
16
				<DESCRIPTION>Find all mdStore with a given format layout and interpretation</DESCRIPTION>
17
				<PARAMETERS/>
18
				<ARCS>
19
					<ARC to="fetchMultipleMDStoreRecords"/>
20
				</ARCS>
21
			</NODE>
22
			<NODE name="fetchMultipleMDStoreRecords" type="FetchMultipleMDStoreRecords">
23
				<DESCRIPTION>Fetch all record from mdstores</DESCRIPTION>
24
				<PARAMETERS>
25
					<PARAM managedBy="system" name="eprParam" required="true" type="string">data_epr</PARAM>
26
				</PARAMETERS>
27
				<ARCS>
28
					<ARC to="feedEnrichedRecords"/>
29
				</ARCS>
30
			</NODE>
31
			<NODE name="feedEnrichedRecords" type="FeedEnrichedRecords">
32
				<DESCRIPTION>Feed Enriched records</DESCRIPTION>
33
				<PARAMETERS>
34
					<PARAM managedBy="system" name="inputEprParam" required="true" type="string">data_epr</PARAM>
35
					<PARAM managedBy="user" name="deduplicatedRecordCSV" required="true" type="string"/>
36
				</PARAMETERS>
37
				<ARCS>
38
					<ARC to="success"/>
39
				</ARCS>
40
			</NODE>
41
		</CONFIGURATION>
42
		<STATUS/>
43
	</BODY>
44
</RESOURCE_PROFILE>
45

  
46

  

Also available in: Unified diff