cosmos changed back to the key

config.py

@@ -38,7 +38,7 @@ class CosmosDBConfig:
     """ Cosmos Databases """
     HOST = os.environ.get('ACCOUNT_HOST',
                           'https://nancycosomsdb.documents.azure.com:443/')
-    KEY = os.environ.get('ACCOUNT_KEY',
+    KEY = os.environ.get('COSMOS_KEY',
                          'fNVRCesO1NAb9MYZNK2rKdAPkY9J4O5ntR8CRuKu6wVGhndiaXch'
                          'Q6fKwrTTnTbv4tPM8S74YjZsfcX4uAHgiw==')
 
@@ -71,4 +71,4 @@ class CosmosDBConfig:
         PARTITION_KEY = PartitionKey(path="/notificationId")
 
 
-COSMOS_CLIENT = CosmosClient(CosmosDBConfig.HOST, AppConfig.CLIENT_ID)
+COSMOS_CLIENT = CosmosClient(CosmosDBConfig.HOST, CosmosDBConfig.KEY)

utils/cosmos_client.py

@@ -48,15 +48,15 @@ class ItemNotFound(CosmosClientException):
 
 class CosmosClient:
     """ Cosmos Client class """
-    def __init__(self, host: str, client_id: str):
+    def __init__(self, host: str, master_key: str):
         self.executor = futures.ThreadPoolExecutor()
-        mgmt_credentials = ManagedIdentityCredential(client_id=client_id)
-        self.client = cosmos_client.CosmosClient(
-            host, mgmt_credentials,
-            consistency_level=documents.ConsistencyLevel.Strong
-        )
-        # self.client = cosmos_client.CosmosClient(host,
-        #                                          dict(masterKey=master_key))
+        # mgmt_credentials = ManagedIdentityCredential(client_id=client_id)
+        # self.client = cosmos_client.CosmosClient(
+        #     host, mgmt_credentials,
+        #     consistency_level=documents.ConsistencyLevel.Strong
+        # )
+        self.client = cosmos_client.CosmosClient(host,
+                                                 dict(masterKey=master_key))
 
     async def execute_blocking(self, bl, *args):
         """ Execute blocking code """