#3.ant.5 (#35)

* #3.ant.5

* 3.ant.5

* Initial work

* Updates

* Updates

* Update CHANGELOG.md

---------

Co-authored-by: docktermj <michael@dockter.com>

Author: antaenc

.gitignore

@@ -165,3 +165,6 @@ cython_debug/
 
 # VSCode
 .vscode/
+
+# Synology NAS files
+.DS_Store

CHANGELOG.md

@@ -10,9 +10,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 -
 
-## [0.0.0] - yyyy-mm-dd
+## [0.0.1] - 2024-04-01
 
-### Added to 0.0.0
+### Added to 0.0.1
 
-- Thing 2
-- Thing 1
+- Before change from G2 to Sz

examples/g2diagnostic/purge_repository.py

@@ -0,0 +1,23 @@
+#! /usr/bin/env python3
+
+from senzing import g2diagnostic
+from senzing.g2exception import G2Exception
+
+INSTANCE_NAME = "Example"
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+
+try:
+    g2_diagnostic = g2diagnostic.G2Diagnostic(INSTANCE_NAME, SETTINGS)
+    # WARNING
+    # WARNING - This will remove all loaded and entity resolved data from the Senzing repository, use with caution!
+    # WARNING
+    g2_diagnostic.purge_repository()
+except G2Exception as err:
+    print(err)

examples/g2engine/__find_interesting_entities_by_entity_id.py

@@ -0,0 +1,23 @@
+#! /usr/bin/env python3
+
+from senzing import g2engine
+from senzing.g2exception import G2Exception
+
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+INSTANCE_NAME = "Example"
+
+ENTITY_ID = 1
+
+try:
+    g2_engine = g2engine.G2Engine(INSTANCE_NAME, SETTINGS)
+    result = g2_engine.find_interesting_entities_by_entity_id(ENTITY_ID)
+    print(result)
+except G2Exception as err:
+    print(err)

examples/g2engine/export_config.py …nd_interesting_entities_by_entity_id.txtexamples/g2engine/export_config.py renamed to examples/g2engine/__find_interesting_entities_by_entity_id.txt examples/g2engine/export_config.py renamed to examples/g2engine/__find_interesting_entities_by_entity_id.txt

@@ -0,0 +1,23 @@
+#! /usr/bin/env python3
+
+from senzing import g2engine
+from senzing.g2exception import G2Exception
+
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+INSTANCE_NAME = "Example"
+
+ENTITY_ID = 1
+
+try:
+    g2_engine = g2engine.G2Engine(INSTANCE_NAME, SETTINGS)
+    result = g2_engine.find_interesting_entities_by_entity_id_return_dict(ENTITY_ID)
+    print(result)
+except G2Exception as err:
+    print(err)

examples/g2engine/__find_interesting_entities_by_entity_id_return_dict.py

@@ -0,0 +1,27 @@
+#! /usr/bin/env python3
+
+from senzing import g2engine
+from senzing.g2exception import G2Exception
+
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+INSTANCE_NAME = "Example"
+
+# TODO Use a truth set entity id - in all examples
+DATA_SOURCE_CODE = "TEST"
+RECORD_ID = "Example-1"
+
+try:
+    g2_engine = g2engine.G2Engine(INSTANCE_NAME, SETTINGS)
+    result = g2_engine.find_interesting_entities_by_record_id(
+        DATA_SOURCE_CODE, RECORD_ID = {
+    )
+    print(result)
+except G2Exception as err:
+    print(err)

examples/g2engine/__find_interesting_entities_by_record_id.py

@@ -0,0 +1,27 @@
+#! /usr/bin/env python3
+
+from senzing import g2engine
+from senzing.g2exception import G2Exception
+
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+INSTANCE_NAME = "Example"
+
+# TODO Use a truth set entity id - in all examples
+DATA_SOURCE_CODE = "TEST"
+RECORD_ID = "Example-1"
+
+try:
+    g2_engine = g2engine.G2Engine(INSTANCE_NAME, SETTINGS)
+    result = g2_engine.find_interesting_entities_by_record_id_return_dict(
+        DATA_SOURCE_CODE, RECORD_ID = {
+    )
+    print(result)
+except G2Exception as err:
+    print(err)

examples/g2engine/export_config.txt …nd_interesting_entities_by_record_id.txtexamples/g2engine/export_config.txt renamed to examples/g2engine/__find_interesting_entities_by_record_id.txt examples/g2engine/export_config.txt renamed to examples/g2engine/__find_interesting_entities_by_record_id.txt

@@ -0,0 +1,48 @@
+#! /usr/bin/env python3
+import json
+import sys
+import time
+from contextlib import suppress
+from datetime import timedelta
+
+from senzing import g2engine, g2engineflags
+from senzing.g2exception import G2Exception
+
+with suppress(ModuleNotFoundError):
+    import orjson
+
+INSTANCE_NAME = "Example"
+ENTITY_ID = 1
+SETTINGS = {
+    "PIPELINE": {
+        "CONFIGPATH": "/etc/opt/senzing",
+        "RESOURCEPATH": "/opt/senzing/g2/resources",
+        "SUPPORTPATH": "/opt/senzing/data",
+    },
+    "SQL": {"CONNECTION": "sqlite3://na:na@/var/opt/senzing/G2C.db"},
+}
+
+try:
+    g2_engine = g2engine.G2Engine(INSTANCE_NAME, SETTINGS)
+except G2Exception as err:
+    print(err)
+    sys.exit()
+
+flags = g2engineflags.G2EngineFlags.G2_ENTITY_BRIEF_DEFAULT_FLAGS
+iterations = 5
+
+
+starttime = time.perf_counter()
+for _ in range(iterations):
+    result = g2_engine.get_entity_by_entity_id(ENTITY_ID, flags)
+    json.loads(result)
+duration = timedelta(seconds=time.perf_counter() - starttime)
+print(f"json duration: {duration}")
+
+if "orjson" in dir():
+    starttime = time.perf_counter()
+    for _ in range(iterations):
+        result = g2_engine.get_entity_by_entity_id(ENTITY_ID, flags)
+        orjson.loads(result)
+    duration = timedelta(seconds=time.perf_counter() - starttime)
+    print(f"orjson duration: {duration}")