-# Copyright (C) 2021 Wind River Systems, Inc.\r
-#\r
-# Licensed under the Apache License, Version 2.0 (the "License");\r
-# you may not use this file except in compliance with the License.\r
-# You may obtain a copy of the License at\r
-#\r
-# http://www.apache.org/licenses/LICENSE-2.0\r
-#\r
-# Unless required by applicable law or agreed to in writing, software\r
-# distributed under the License is distributed on an "AS IS" BASIS,\r
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
-# See the License for the specific language governing permissions and\r
-# limitations under the License.\r
-\r
-from retry import retry\r
-from sqlalchemy import (\r
- Table,\r
- MetaData,\r
- Column,\r
- Integer,\r
- String,\r
- Text,\r
- # Date,\r
- DateTime,\r
- # ForeignKey,\r
- # engine,\r
- # event,\r
- exc\r
-)\r
-\r
-from sqlalchemy.orm import mapper\r
-from o2dms.domain import dms as dmsModel\r
-\r
-from o2common.helper import o2logging\r
-logger = o2logging.get_logger(__name__)\r
-\r
-metadata = MetaData()\r
-\r
-nfDeploymentDesc = Table(\r
- "nfDeploymentDesc",\r
- metadata,\r
- Column("updatetime", DateTime),\r
- Column("createtime", DateTime),\r
- Column("hash", String(255)),\r
- Column("version_number", Integer),\r
-\r
- Column("id", String(255), primary_key=True),\r
- Column("deploymentManagerId", String(255)),\r
- Column("name", String(255)),\r
- Column("description", String(255)),\r
- Column("inputParams", Text()),\r
- Column("outputParams", String(255)),\r
- Column("artifactRepoUrl", String(255)),\r
- Column("artifactName", String(255)),\r
- # Column("extensions", String(1024))\r
-)\r
-\r
-nfDeployment = Table(\r
- "nfDeployment",\r
- metadata,\r
- Column("updatetime", DateTime),\r
- Column("createtime", DateTime),\r
- Column("hash", String(255)),\r
- Column("version_number", Integer),\r
-\r
- Column("id", String(255), primary_key=True),\r
- Column("deploymentManagerId", String(255)),\r
- Column("name", String(255)),\r
- Column("description", String(255)),\r
- Column("descriptorId", String(255)),\r
- Column("parentDeploymentId", String(255)),\r
- Column("status", Integer)\r
-)\r
-\r
-nfOCloudVResource = Table(\r
- "nfOcloudVRes",\r
- metadata,\r
- Column("updatetime", DateTime),\r
- Column("createtime", DateTime),\r
- Column("hash", String(255)),\r
- Column("version_number", Integer),\r
-\r
- Column("id", String(255), primary_key=True),\r
- Column("deploymentManagerId", String(255)),\r
- Column("name", String(255)),\r
- Column("description", String(255)),\r
- Column("descriptorId", String(255)),\r
- Column("vresourceType", String(255)),\r
- Column("status", Integer),\r
- Column("metadata", String(2048)),\r
- Column("nfDeploymentId", String(255))\r
-)\r
-\r
-\r
-@retry((exc.IntegrityError), tries=3, delay=2)\r
-def wait_for_metadata_ready(engine):\r
- # wait for mapper ready\r
- metadata.create_all(engine, checkfirst=True)\r
- logger.info("metadata is ready")\r
-\r
-\r
-def start_o2dms_mappers(engine=None):\r
- logger.info("Starting O2 DMS mappers")\r
-\r
- mapper(dmsModel.NfDeploymentDesc, nfDeploymentDesc)\r
- mapper(dmsModel.NfDeployment, nfDeployment)\r
- mapper(dmsModel.NfOCloudVResource, nfOCloudVResource)\r
-\r
- if engine is not None:\r
- wait_for_metadata_ready(engine)\r
+# Copyright (C) 2021 Wind River Systems, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from retry import retry
+from sqlalchemy import (
+ Table,
+ MetaData,
+ Column,
+ Integer,
+ String,
+ Text,
+ # Date,
+ DateTime,
+ # ForeignKey,
+ # engine,
+ # event,
+ exc
+)
+
+from sqlalchemy.orm import mapper
+from o2dms.domain import dms as dmsModel
+
+from o2common.helper import o2logging
+logger = o2logging.get_logger(__name__)
+
+metadata = MetaData()
+
+nfDeploymentDesc = Table(
+ "nfDeploymentDesc",
+ metadata,
+ Column("updatetime", DateTime),
+ Column("createtime", DateTime),
+ Column("hash", String(255)),
+ Column("version_number", Integer),
+
+ Column("id", String(255), primary_key=True),
+ Column("deploymentManagerId", String(255)),
+ Column("name", String(255)),
+ Column("description", String(255)),
+ Column("inputParams", Text()),
+ Column("outputParams", String(255)),
+ Column("artifactRepoUrl", String(255)),
+ Column("artifactName", String(255)),
+ # Column("extensions", String(1024))
+)
+
+nfDeployment = Table(
+ "nfDeployment",
+ metadata,
+ Column("updatetime", DateTime),
+ Column("createtime", DateTime),
+ Column("hash", String(255)),
+ Column("version_number", Integer),
+
+ Column("id", String(255), primary_key=True),
+ Column("deploymentManagerId", String(255)),
+ Column("name", String(255)),
+ Column("description", String(255)),
+ Column("descriptorId", String(255)),
+ Column("parentDeploymentId", String(255)),
+ Column("status", Integer)
+)
+
+nfOCloudVResource = Table(
+ "nfOcloudVRes",
+ metadata,
+ Column("updatetime", DateTime),
+ Column("createtime", DateTime),
+ Column("hash", String(255)),
+ Column("version_number", Integer),
+
+ Column("id", String(255), primary_key=True),
+ Column("deploymentManagerId", String(255)),
+ Column("name", String(255)),
+ Column("description", String(255)),
+ Column("descriptorId", String(255)),
+ Column("vresourceType", String(255)),
+ Column("status", Integer),
+ Column("metadata", String(2048)),
+ Column("nfDeploymentId", String(255))
+)
+
+
+@retry((exc.IntegrityError), tries=3, delay=2)
+def wait_for_metadata_ready(engine):
+ # wait for mapper ready
+ metadata.create_all(engine, checkfirst=True)
+ logger.info("metadata is ready")
+
+
+def start_o2dms_mappers(engine=None):
+ logger.info("Starting O2 DMS mappers")
+
+ mapper(dmsModel.NfDeploymentDesc, nfDeploymentDesc)
+ mapper(dmsModel.NfDeployment, nfDeployment)
+ mapper(dmsModel.NfOCloudVResource, nfOCloudVResource)
+
+ if engine is not None:
+ wait_for_metadata_ready(engine)
Code Review / pti / o2.git / blobdiff