Commit 13c07152 by Oleksandr Barabash

additional loggs added

parent d9947178
""" Cosmos Client implementation """ """ Cosmos Client implementation """
import asyncio import asyncio
import sys
import uuid import uuid
from concurrent import futures from concurrent import futures
from typing import Any, Dict, Optional, Union, List from typing import Any, Dict, Optional, Union, List
...@@ -18,6 +19,7 @@ from entities.json.camel_case_mixin import timestamp_factory ...@@ -18,6 +19,7 @@ from entities.json.camel_case_mixin import timestamp_factory
from entities.json.conversation_reference import ConversationReference from entities.json.conversation_reference import ConversationReference
from entities.json.initiation import Initiation from entities.json.initiation import Initiation
from entities.json.notification import NotificationCosmos from entities.json.notification import NotificationCosmos
from utils.log import Log
class CosmosClientException(Exception): class CosmosClientException(Exception):
...@@ -84,10 +86,10 @@ class CosmosClient: ...@@ -84,10 +86,10 @@ class CosmosClient:
def bl() -> ContainerProxy: def bl() -> ContainerProxy:
""" Get Notifications container blocking """ """ Get Notifications container blocking """
try: try:
return db.get_container_client(container_id)
except exceptions.CosmosResourceNotFoundError:
return db.create_container(container_id, partition_key, return db.create_container(container_id, partition_key,
**kwargs) **kwargs)
except exceptions.CosmosResourceExistsError:
return db.get_container_client(container_id)
return await self.execute_blocking(bl) return await self.execute_blocking(bl)
...@@ -311,6 +313,7 @@ class CosmosClient: ...@@ -311,6 +313,7 @@ class CosmosClient:
""" Save Conversation Regerence """ """ Save Conversation Regerence """
from config import CosmosDBConfig from config import CosmosDBConfig
Log.i(__name__, "create_conversation_reference")
activity = turn_context.activity activity = turn_context.activity
reference = TurnContext.get_conversation_reference(activity) reference = TurnContext.get_conversation_reference(activity)
reference_json = ConversationReference.get_schema().dump(reference) reference_json = ConversationReference.get_schema().dump(reference)
...@@ -327,6 +330,8 @@ class CosmosClient: ...@@ -327,6 +330,8 @@ class CosmosClient:
try: try:
return await self.execute_blocking(bl) return await self.execute_blocking(bl)
except exceptions.CosmosHttpResponseError as e: except exceptions.CosmosHttpResponseError as e:
Log.i(__name__, "create_conversation_reference::error:",
sys.exc_info())
if e.status_code == 409: # Already exists if e.status_code == 409: # Already exists
return return
raise SaveItemError(e.http_error_message) raise SaveItemError(e.http_error_message)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment