1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
|
"""Copyright 2019 Deutsche Telekom.
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.
"""
import socket
from datetime import datetime, timezone
from functools import wraps
from logging import Logger
from typing import NoReturn, Union
from grpc import ServicerContext
from manager.configuration import get_logger
from manager.errors import ArtifactManagerError, InvalidRequestError
from manager.utils import Repository, RepositoryStrategy
from onaplogging.mdcContext import MDC
from proto.BluePrintManagement_pb2 import (
BluePrintDownloadInput,
BluePrintManagementOutput,
BluePrintRemoveInput,
BluePrintUploadInput,
)
from proto.BluePrintManagement_pb2_grpc import BluePrintManagementServiceServicer
MDC_DATETIME_FORMAT = r"%Y-%m-%dT%H:%M:%S.%f%z"
COMMON_HEADER_DATETIME_FORMAT = r"%Y-%m-%dT%H:%M:%S.%fZ"
def fill_common_header(func):
"""Decorator to fill handler's output values which is the same type for each handler.
It copies commonHeader from request object and set timestamp value.
:param func: Handler function
:return: _handler decorator callable object
"""
@wraps(func)
def _decorator(
servicer: "ArtifactManagerServicer",
request: Union[BluePrintDownloadInput, BluePrintRemoveInput, BluePrintUploadInput],
context: ServicerContext,
) -> BluePrintManagementOutput:
if not all([request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion]):
raise InvalidRequestError("Request has to have set both BluePrint name and version")
output: BluePrintManagementOutput = func(servicer, request, context)
# Set same values for every handler
output.commonHeader.CopyFrom(request.commonHeader)
output.commonHeader.timestamp = datetime.utcnow().strftime(COMMON_HEADER_DATETIME_FORMAT)
return output
return _decorator
def translate_exception_to_response(func):
"""Decorator that translates Artifact Manager exceptions into proper responses.
:param func: Handler function
:return: _handler decorator callable object
"""
@wraps(func)
def _handler(
servicer: "ArtifactManagerServicer",
request: Union[BluePrintDownloadInput, BluePrintRemoveInput, BluePrintUploadInput],
context: ServicerContext,
) -> BluePrintManagementOutput:
try:
output: BluePrintManagementOutput = func(servicer, request, context)
output.status.code = 200
output.status.message = "success"
except ArtifactManagerError as error:
# If ArtifactManagerError is raises one of defined error occurs.
# Every ArtifactManagerError based exception has status_code paramenter
# which has to be set in output. Use also exception's message to
# set errorMessage of the output.
output: BluePrintManagementOutput = BluePrintManagementOutput()
output.status.code = error.status_code
output.status.message = "failure"
output.status.errorMessage = str(error.message)
servicer.fill_MDC_timestamps()
servicer.logger.error(
"Error while processing the message - blueprintName={} blueprintVersion={}".format(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
),
extra={"mdc": MDC.result()},
)
MDC.clear()
return output
return _handler
def prepare_logging_context(func):
"""Decorator that prepares MDC logging context for logs inside the handler.
:param func: Handler function
:return: _handler decorator callable object
"""
@wraps(func)
def _decorator(
servicer: "ArtifactManagerServicer",
request: Union[BluePrintDownloadInput, BluePrintRemoveInput, BluePrintUploadInput],
context: ServicerContext,
) -> BluePrintManagementOutput:
MDC.put("RequestID", request.commonHeader.requestId)
MDC.put("InvocationID", request.commonHeader.subRequestId)
MDC.put("ServiceName", servicer.__class__.__name__)
MDC.put("PartnerName", request.commonHeader.originatorId)
started_at = datetime.utcnow().replace(tzinfo=timezone.utc)
MDC.put("BeginTimestamp", started_at.strftime(MDC_DATETIME_FORMAT))
# Adding processing_started_at to the servicer so later we'll have the data to calculate elapsed time.
servicer.processing_started_at = started_at
MDC.put("TargetEntity", "py-executor")
MDC.put("TargetServiceName", func.__name__)
MDC.put("Server", socket.getfqdn())
output: BluePrintManagementOutput = func(servicer, request, context)
MDC.clear()
return output
return _decorator
class ArtifactManagerServicer(BluePrintManagementServiceServicer):
"""ArtifactManagerServer class.
Implements methods defined in proto files to manage artifacts repository.
These methods are: download, upload and remove.
"""
processing_started_at = None
def __init__(self) -> NoReturn:
"""Instance of ArtifactManagerServer class initialization.
Create logger for class using class name and set configuration property.
"""
self.logger: Logger = get_logger(self.__class__.__name__)
self.repository: Repository = RepositoryStrategy.get_reporitory()
def fill_MDC_timestamps(self, status_code: int = 200) -> NoReturn:
"""Add MDC context timestamps "in place".
:param status_code: int with expected response status. Default: 200 (success)
"""
now = datetime.utcnow().replace(tzinfo=timezone.utc)
MDC.put("EndTimestamp", now.strftime(MDC_DATETIME_FORMAT))
# Elapsed time measured in miliseconds
MDC.put("ElapsedTime", (now - self.processing_started_at).total_seconds() * 1000)
MDC.put("StatusCode", status_code)
@prepare_logging_context
@translate_exception_to_response
@fill_common_header
def downloadBlueprint(self, request: BluePrintDownloadInput, context: ServicerContext) -> BluePrintManagementOutput:
"""Download blueprint file request method.
Currently it only logs when is called and all base class method.
:param request: BluePrintDownloadInput
:param context: ServicerContext
:return: BluePrintManagementOutput
"""
output: BluePrintManagementOutput = BluePrintManagementOutput()
output.fileChunk.chunk = self.repository.download_blueprint(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
)
self.fill_MDC_timestamps()
self.logger.info(
"Blueprint download successfuly processed - blueprintName={} blueprintVersion={}".format(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
),
extra={"mdc": MDC.result()},
)
return output
@prepare_logging_context
@translate_exception_to_response
@fill_common_header
def uploadBlueprint(self, request: BluePrintUploadInput, context: ServicerContext) -> BluePrintManagementOutput:
"""Upload blueprint file request method.
Currently it only logs when is called and all base class method.
:param request: BluePrintUploadInput
:param context: ServicerContext
:return: BluePrintManagementOutput
"""
self.repository.upload_blueprint(
request.fileChunk.chunk, request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
)
self.fill_MDC_timestamps()
self.logger.info(
"Blueprint upload successfuly processed - blueprintName={} blueprintVersion={}".format(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
),
extra={"mdc": MDC.result()},
)
return BluePrintManagementOutput()
@prepare_logging_context
@translate_exception_to_response
@fill_common_header
def removeBlueprint(self, request: BluePrintRemoveInput, context: ServicerContext) -> BluePrintManagementOutput:
"""Remove blueprint file request method.
Currently it only logs when is called and all base class method.
:param request: BluePrintRemoveInput
:param context: ServicerContext
:return: BluePrintManagementOutput
"""
self.repository.remove_blueprint(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
)
self.fill_MDC_timestamps()
self.logger.info(
"Blueprint removal successfuly processed - blueprintName={} blueprintVersion={}".format(
request.actionIdentifiers.blueprintName, request.actionIdentifiers.blueprintVersion
),
extra={"mdc": MDC.result()},
)
return BluePrintManagementOutput()
|
