Merge pull request #8455 from mandy-chessell/oak2024

Add lineage metadata to CocoComboArchive.omarchive
odpi · Oct 21, 2024 · 65800a6 · 65800a6
2 parents bb617bc + 867c28a
commit 65800a6
Show file tree

Hide file tree

Showing 14 changed files with 537 additions and 31 deletions.
diff --git a/EgeriaContentPacksGUIDMap.json b/EgeriaContentPacksGUIDMap.json
diff --git a/content-packs/CocoBusinessSystemsArchive.omarchive b/content-packs/CocoBusinessSystemsArchive.omarchive
diff --git a/content-packs/CocoClinicalTrialsTemplatesArchive.omarchive b/content-packs/CocoClinicalTrialsTemplatesArchive.omarchive
diff --git a/content-packs/CocoComboArchive.omarchive b/content-packs/CocoComboArchive.omarchive
diff --git a/content-packs/CocoGovernanceEngineDefinitionsArchive.omarchive b/content-packs/CocoGovernanceEngineDefinitionsArchive.omarchive
diff --git a/content-packs/CocoGovernanceProgramArchive.omarchive b/content-packs/CocoGovernanceProgramArchive.omarchive
diff --git a/content-packs/CocoOrganizationArchive.omarchive b/content-packs/CocoOrganizationArchive.omarchive
diff --git a/content-packs/CocoSustainabilityArchive.omarchive b/content-packs/CocoSustainabilityArchive.omarchive
diff --git a/content-packs/CocoTypesArchive.omarchive b/content-packs/CocoTypesArchive.omarchive
diff --git a/.../main/java/org/odpi/openmetadata/samples/archiveutilities/SimpleCatalogArchiveHelper.java b/.../main/java/org/odpi/openmetadata/samples/archiveutilities/SimpleCatalogArchiveHelper.java
@@ -3652,6 +3652,41 @@ public void addDataContentForDataSet(String dataContentGUID,
     }
 
 
+
+
+    /**
+     * Create a lineage relationship between the two elements
+     *
+     * @param sourceGUID unique identifier of the element at end 1
+     * @param destinationGUID unique identifier of the element at end 2
+     * @param relationshipType type name of lineage relationship
+     * @param description description of the relationship
+     */
+    public void addLineageRelationship(String sourceGUID,
+                                       String destinationGUID,
+                                       String relationshipType,
+                                       String description)
+    {
+        final String methodName = "addLineageRelationship";
+
+        EntityDetail end1Entity = archiveBuilder.getEntity(sourceGUID);
+        EntityDetail end2Entity = archiveBuilder.getEntity(destinationGUID);
+
+        EntityProxy end1 = archiveHelper.getEntityProxy(end1Entity);
+        EntityProxy end2 = archiveHelper.getEntityProxy(end2Entity);
+
+        InstanceProperties properties = archiveHelper.addStringPropertyToInstance(archiveRootName, null, OpenMetadataProperty.DESCRIPTION.name, description, methodName);
+
+        archiveBuilder.addRelationship(archiveHelper.getRelationship(relationshipType,
+                                                                     idToGUIDMap.getGUID(sourceGUID + "_to_" + destinationGUID + "_" + relationshipType + "_" + description + "_relationship"),
+                                                                     properties,
+                                                                     InstanceStatus.ACTIVE,
+                                                                     end1,
+                                                                     end2));
+    }
+
+
+
     /**
      * Create a DataStoreEncoding classification containing the supplied properties.
      *

diff --git a/...enmetadata/samples/archiveutilities/businesssystems/CocoBusinessSystemsArchiveWriter.java b/...enmetadata/samples/archiveutilities/businesssystems/CocoBusinessSystemsArchiveWriter.java
@@ -4,6 +4,7 @@
 
 
 import org.odpi.openmetadata.archiveutilities.openconnectors.core.CorePackArchiveWriter;
+import org.odpi.openmetadata.frameworks.openmetadata.controls.PlaceholderProperty;
 import org.odpi.openmetadata.frameworks.openmetadata.types.OpenMetadataProperty;
 import org.odpi.openmetadata.frameworks.openmetadata.types.OpenMetadataType;
 import org.odpi.openmetadata.repositoryservices.connectors.stores.archivestore.properties.OpenMetadataArchive;
@@ -57,6 +58,7 @@ public void getArchiveContent()
     {
         addHosts();
         addSystems();
+        addSystemLineage();
     }
 
 
@@ -100,7 +102,7 @@ private void addSystems()
             extendedProperties.put(OpenMetadataProperty.DEPLOYED_IMPLEMENTATION_TYPE.name, systemDefinition.getSystemType().getPreferredValue());
             extendedProperties.put(OpenMetadataProperty.USER_ID.name, systemDefinition.getUserId());
 
-
+            archiveHelper.setGUID(systemDefinition.getQualifiedName(), systemDefinition.getSystemGUID());
             String serverGUID = archiveHelper.addAsset(OpenMetadataType.SOFTWARE_SERVER.typeName,
                                                        systemDefinition.getQualifiedName(),
                                                        systemDefinition.getSystemId(),
@@ -109,7 +111,7 @@ private void addSystems()
                                                        systemDefinition.getZones(),
                                                        null,
                                                        extendedProperties);
-
+            assert(serverGUID.equals(systemDefinition.getSystemGUID()));
 
 
             if (systemDefinition.getSystemType().getServerPurpose() != null)
@@ -170,5 +172,24 @@ private void addSystems()
             }
         }
     }
+
+
+
+    /**
+     * The systems define the hosts.
+     */
+    private void addSystemLineage()
+    {
+        for (SystemLevelLineage systemLevelLineage : SystemLevelLineage.values())
+        {
+            archiveHelper.addLineageRelationship(systemLevelLineage.getSourceSystem().getSystemGUID(),
+                                                 systemLevelLineage.getDestinationSystem().getSystemGUID(),
+                                                 systemLevelLineage.getRelationshipName(),
+                                                 systemLevelLineage.getRelationshipDescription());
+
+
+        }
+    }
+
 }
 
diff --git a/...n/java/org/odpi/openmetadata/samples/archiveutilities/businesssystems/HostDefinition.java b/...n/java/org/odpi/openmetadata/samples/archiveutilities/businesssystems/HostDefinition.java
@@ -13,6 +13,20 @@
  */
 public enum HostDefinition
 {
+    /**
+     * ams03 - Amsterdam data centre standard machine 02.
+     */
+    COCO_MFG_PLANNING_AMS_HOST("ams03",
+                              "Amsterdam data centre standard machine 03.",
+                              HostTypeDefinition.BARE_METAL,
+                              FacilityDefinition.AMSTERDAM_DC,
+                              "https://ams03.coco.com",
+                              "Ubuntu",
+                              "23.04",
+                              null,
+                              new String[]{"machines"},
+                              0),
+
     /**
      * ams45 - Amsterdam data centre standard machine 45.
      */
@@ -97,6 +111,20 @@ public enum HostDefinition
                         new String[]{"machines"},
                         0),
 
+    /**
+     * ams04 - Amsterdam data centre standard machine 04.
+     */
+    COCO_SUS_AMS_HOST("ams04",
+                      "Amsterdam data centre standard machine 04.",
+                      HostTypeDefinition.BARE_METAL,
+                      FacilityDefinition.AMSTERDAM_DC,
+                      "https://ams04.coco.com",
+                      "Ubuntu",
+                      "23.04",
+                      null,
+                      new String[]{"machines"},
+                      500),
+
     /**
      * ams02 - Amsterdam data centre standard machine 02.
      */