1.8.4

examples_v2/set_obj_id.py

@@ -0,0 +1,253 @@
+import json
+import os
+import requests.exceptions
+from typing import Optional, Dict, List
+from urllib import parse
+import re
+from collections import Counter
+
+from src.thoughtspot_rest_api_v1 import TSRestApiV2, TSTypesV2, ReportTypes, TSRestApiV1
+
+username = os.getenv('username')  # or type in yourself
+password = os.getenv('password')  # or type in yourself
+server = os.getenv('server')        # or type in yourself
+org_id = 0
+
+ts = TSRestApiV2(server_url=server)
+try:
+    auth_token_response = ts.auth_token_full(username=username, password=password,
+                                               validity_time_in_sec=3000, org_id=org_id)
+    ts.bearer_token = auth_token_response['token']
+except requests.exceptions.HTTPError as e:
+    print(e)
+    print(e.response.content)
+    exit()
+
+def create_obj_id_update_request(guid: str, obj_id: str):
+    update_req = {
+        "headers_update":
+            (
+                {'identifier': guid,
+                 'attributes': (
+                     {
+                         'name': 'obj_id',
+                         'value': obj_id
+                     }
+                 )
+                 }
+            )
+    }
+    return update_req
+
+# { 'guid' : 'obj_id' }
+def create_multi_obj_id_update_request(guid_obj_id_map: Dict):
+    update_req = {
+        "headers_update": []
+    }
+    for guid in guid_obj_id_map:
+        header_item = {
+            'identifier': guid,
+            'attributes': (
+                 {
+                     'name': 'obj_id',
+                     'value': guid_obj_id_map[guid]
+                 }
+            )
+         }
+        update_req["headers_update"].append(header_item)
+
+    return update_req
+
+def set_one_object():
+    # Simple example of setting a Table object to have a Full Qualified Name as the obj_id
+    update_req = create_obj_id_update_request(guid='43ab8a16-473a-44dc-9c78-4346eeb51f6c', obj_id='Conn.DB_Name.TableName')
+
+    resp = ts.metadata_headers_update(request=update_req)
+    print(json.dumps(resp, indent=2))
+
+
+def export_tml_with_obj_id(guid:Optional[str] = None,
+                           obj_id: Optional[str] = None,
+                           save_to_disk=True):
+    # Example of metadata search using obj_identifier (the property may be updated?)
+    if obj_id is not None:
+        search_req = {
+            "metadata": (
+                {'obj_identifier': obj_id}
+            ),
+            "sort_options": {
+                "field_name": "CREATED",
+                "order": "DESC"
+            }
+        }
+
+        tables = ts.metadata_search(request=search_req)
+        if len(tables) == 1:
+            guid = tables[0]['metadata_id']
+            obj_id = tables[0]['metadata_header']['objId']
+
+        # print(json.dumps(log_tables, indent=2))
+
+    if guid is None:
+        raise Exception()
+
+    # export_options allow shifting TML export to obj_id, without any guid references
+    exp_opt = {
+        "include_obj_id_ref": True,
+        "include_guid": False,
+        "include_obj_id": True
+    }
+
+
+    yaml_tml = ts.metadata_tml_export(metadata_ids=[guid], edoc_format='YAML',
+                                      export_options=exp_opt)
+
+    if save_to_disk is True:
+        print(yaml_tml[0]['edoc'])
+        print("-------")
+
+        # Save the file with {obj_id}.{type}.{tml}
+        filename = "{}.table.tml".format(obj_id)
+        with open(file=filename, mode='w') as f:
+            f.write(yaml_tml[0]['edoc'])
+
+    return yaml_tml
+
+def retrieve_dev_org_objects_for_mapping(org_name: Optional[str] = None, org_id: Optional[int] = None):
+
+    if org_id is None:
+        org_req = {
+            "org_identifier": org_name
+        }
+        org_resp = ts.orgs_search(request=org_req)
+        if len(org_resp) == 1:
+            org_id = org_resp[0]["id"]
+        else:
+            raise Exception("No org with that org_name was found, please try again or provide org_id")
+
+    ts2 = TSRestApiV2(server_url=server)
+    try:
+        auth_token_response = ts2.auth_token_full(username=username, password=password,
+                                                 validity_time_in_sec=3000, org_id=org_id)
+        ts.bearer_token = auth_token_response['token']
+    except requests.exceptions.HTTPError as e:
+        print(e)
+        print(e.response.content)
+        exit()
+
+    types = ["LOGICAL_TABLE", "LIVEBOARD", "ANSWER"]
+    search_req = {
+        "record_offset": 0,
+        "record_size": -1,
+        "include_headers": True,
+        "include_details": True,
+        "metadata":[
+            {"type": "LOGICAL_TABLE"},{"type": "LIVEBOARD"},{"type": "ANSWER"}
+        ]
+        ,
+        "sort_options": {
+            "field_name": "CREATED",
+            "order": "DESC"
+        }
+    }
+
+    conn_req = {
+        "record_offset": 0,
+        "record_size": -1,
+        "include_headers": False,
+        "include_details": False,
+        "metadata": [
+            {
+                "type": "CONNECTION"
+            }
+        ]
+        ,
+        "sort_options": {
+            "field_name": "CREATED",
+            "order": "DESC"
+        }
+    }
+
+    # Tables - split out Worksheets/ Models / Views from actual Table Objects
+    try:
+        tables_resp = ts2.metadata_search(request=search_req)
+    except requests.exceptions.HTTPError as e:
+        print(e)
+        print(e.response.content)
+        exit()
+
+    # Connection names for mapping and use in obj_id naming schema for Tables
+    try:
+        conn_resp = ts2.metadata_search(request=conn_req)
+    except requests.exceptions.HTTPError as e:
+        print(e)
+        print(e.response.content)
+        exit()
+
+    conn_map = {}
+    for conn in conn_resp:
+        # Create URL safe portion of obj_id for Connection
+        # Assuming No Duplicate Connection Names in Org (fix this first if you don't have)
+        # Define whatever automatic transformations to create URL safe
+        # but aesthetically pleasing first transform from the existing object names
+        c_obj_id = conn["metadata_name"].replace(" ", "")
+        c_obj_id = parse.quote(c_obj_id)
+        # obj_id = obj_id.replace("%3A", "_")
+        # After parse quoting, there characters are in form %XX , replace with _ or blank space
+        c_obj_id = re.sub(r"%..", "", c_obj_id)
+        conn_map[conn["metadata_id"]] = c_obj_id
+    # print(json.dumps(tables_resp, indent=2))
+
+    final_guid_obj_id_map = {}
+
+    for table in tables_resp:
+        ds_type = table["metadata_header"]["type"]
+
+        guid = table["metadata_id"]
+
+        # Special property for certain system items that exist across all orgs - skip, cannot reset except in Org 0
+        if "belongToAllOrgs" in table["metadata_header"]:
+            if table["metadata_header"]["belongToAllOrgs"] is True:
+                continue
+
+        # Real tables
+        if ds_type in ['ONE_TO_ONE_LOGICAL']:
+            detail = table["metadata_detail"]
+            db_table_details = detail["logicalTableContent"]["tableMappingInfo"]
+
+            # Assumes a "{db}__{schema}__{tableName}" naming convention, but
+            # {tsConnection}__{table} may make more sense across a number of Orgs with identical 'schemas' with
+            # differing names
+            # Essentially you want identical, unique obj_id for "the same table" across Orgs
+            obj_id = "{}__{}__{}".format(db_table_details["databaseName"], db_table_details["schemaName"],
+                                         db_table_details["tableName"])
+        else:
+            # For non-table objects, obj_ids just need to be URL safe strings
+            # This is an example of a basic transformation from the Display Name to a URL safe string
+            obj_id = table["metadata_name"].replace(" ", "_")   # Need more transformation
+            obj_id = parse.quote(obj_id)
+            # After parse quoting, there characters are in form %XX , replace with _ or blank space
+            obj_id = re.sub(r"%..", "", obj_id)
+
+        final_guid_obj_id_map[guid] = obj_id
+
+    # print(json.dumps(final_guid_obj_id_map, indent=2))
+
+    return final_guid_obj_id_map
+
+def find_duplicate_obj_ids(initial_map: Dict) -> Dict:
+    cnt = Counter(initial_map.values())
+
+    if len(initial_map) == len(cnt):
+        return {}
+    else:
+        duplicate_obj_ids = []
+        for c in cnt:
+            if cnt[c] > 1:
+                duplicate_obj_ids.append(c)
+        dup_map = {}
+
+        for m in initial_map:
+            if initial_map[m] in duplicate_obj_ids:
+                dup_map[m] = initial_map[m]
+        return dup_map

requirements.txt

@@ -0,0 +1,2 @@
+requests
+requests-toolbelt

setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = thoughtspot_rest_api_v1
-version = 1.8.2
+version = 1.8.4
 description = Library implementing the ThoughtSpot V1 REST API
 long_description = file: README.md
 long_description_content_type = text/markdown
@@ -26,8 +26,6 @@ packages = find:
 python_requires = >=3.6
 install_requires =
     requests
-    PyYAML
-    oyaml
     requests_toolbelt
 
 

src/thoughtspot_rest_api_v1/_version.py

@@ -1 +1 @@
-__version__ = '1.8.2'
+__version__ = '1.8.4'