perxis.files.files_pb2_grpc
Client and server classes corresponding to protobuf-defined services.
1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2"""Client and server classes corresponding to protobuf-defined services.""" 3import grpc 4import warnings 5 6from perxis.files import files_pb2 as files_dot_files__pb2 7from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 8 9GRPC_GENERATED_VERSION = '1.67.1' 10GRPC_VERSION = grpc.__version__ 11_version_not_supported = False 12 13try: 14 from grpc._utilities import first_version_is_lower 15 _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) 16except ImportError: 17 _version_not_supported = True 18 19if _version_not_supported: 20 raise RuntimeError( 21 f'The grpc package installed is at version {GRPC_VERSION},' 22 + f' but the generated code in files/files_pb2_grpc.py depends on' 23 + f' grpcio>={GRPC_GENERATED_VERSION}.' 24 + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' 25 + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' 26 ) 27 28 29class FilesStub(object): 30 """Missing associated documentation comment in .proto file.""" 31 32 def __init__(self, channel): 33 """Constructor. 34 35 Args: 36 channel: A grpc.Channel. 37 """ 38 self.StartUpload = channel.unary_unary( 39 '/files.Files/StartUpload', 40 request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString, 41 response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString, 42 _registered_method=True) 43 self.CompleteUpload = channel.unary_unary( 44 '/files.Files/CompleteUpload', 45 request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 46 response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString, 47 _registered_method=True) 48 self.AbortUpload = channel.unary_unary( 49 '/files.Files/AbortUpload', 50 request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString, 51 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 52 _registered_method=True) 53 self.MoveUpload = channel.unary_unary( 54 '/files.Files/MoveUpload', 55 request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString, 56 response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString, 57 _registered_method=True) 58 self.Upload = channel.unary_unary( 59 '/files.Files/Upload', 60 request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString, 61 response_deserializer=files_dot_files__pb2.UploadResponse.FromString, 62 _registered_method=True) 63 self.GetFile = channel.unary_unary( 64 '/files.Files/GetFile', 65 request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString, 66 response_deserializer=files_dot_files__pb2.GetFileResponse.FromString, 67 _registered_method=True) 68 self.DeleteFile = channel.unary_unary( 69 '/files.Files/DeleteFile', 70 request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString, 71 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 72 _registered_method=True) 73 74 75class FilesServicer(object): 76 """Missing associated documentation comment in .proto file.""" 77 78 def StartUpload(self, request, context): 79 """StartUpload - инициирует процедуру загрузки файла в файловое хранилище. 80 Используется клиентским приложением для начала загрузки файла 81 Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором 82 обязательные поля Name и Size. 83 Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID. 84 """ 85 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 86 context.set_details('Method not implemented!') 87 raise NotImplementedError('Method not implemented!') 88 89 def CompleteUpload(self, request, context): 90 """CompleteUpload - завершает процедуру загрузку файла 91 Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле 92 Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload` 93 """ 94 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 95 context.set_details('Method not implemented!') 96 raise NotImplementedError('Method not implemented!') 97 98 def AbortUpload(self, request, context): 99 """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища 100 """ 101 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 102 context.set_details('Method not implemented!') 103 raise NotImplementedError('Method not implemented!') 104 105 def MoveUpload(self, request, context): 106 """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения. 107 После перемещение загрузки хранилище выдает новый идентификатор постоянного файла 108 """ 109 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 110 context.set_details('Method not implemented!') 111 raise NotImplementedError('Method not implemented!') 112 113 def Upload(self, request, context): 114 """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL. 115 Завершение загрузки файла осуществляется выполнением POST-запроса 116 """ 117 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 118 context.set_details('Method not implemented!') 119 raise NotImplementedError('Method not implemented!') 120 121 def GetFile(self, request, context): 122 """GetFile - получить информацию о файле (ссылку) по ID 123 """ 124 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 125 context.set_details('Method not implemented!') 126 raise NotImplementedError('Method not implemented!') 127 128 def DeleteFile(self, request, context): 129 """DeleteFile - удаляет файл. Если происходит удаление оригинала, 130 удаляются и все связанные структуры 131 Возможны следующие ситуации: 132 - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы. 133 - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name' 134 - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type' 135 """ 136 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 137 context.set_details('Method not implemented!') 138 raise NotImplementedError('Method not implemented!') 139 140 141def add_FilesServicer_to_server(servicer, server): 142 rpc_method_handlers = { 143 'StartUpload': grpc.unary_unary_rpc_method_handler( 144 servicer.StartUpload, 145 request_deserializer=files_dot_files__pb2.StartUploadRequest.FromString, 146 response_serializer=files_dot_files__pb2.StartUploadResponse.SerializeToString, 147 ), 148 'CompleteUpload': grpc.unary_unary_rpc_method_handler( 149 servicer.CompleteUpload, 150 request_deserializer=files_dot_files__pb2.CompleteUploadRequest.FromString, 151 response_serializer=files_dot_files__pb2.CompleteUploadResponse.SerializeToString, 152 ), 153 'AbortUpload': grpc.unary_unary_rpc_method_handler( 154 servicer.AbortUpload, 155 request_deserializer=files_dot_files__pb2.AbortUploadRequest.FromString, 156 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 157 ), 158 'MoveUpload': grpc.unary_unary_rpc_method_handler( 159 servicer.MoveUpload, 160 request_deserializer=files_dot_files__pb2.MoveUploadRequest.FromString, 161 response_serializer=files_dot_files__pb2.MoveUploadResponse.SerializeToString, 162 ), 163 'Upload': grpc.unary_unary_rpc_method_handler( 164 servicer.Upload, 165 request_deserializer=files_dot_files__pb2.UploadRequest.FromString, 166 response_serializer=files_dot_files__pb2.UploadResponse.SerializeToString, 167 ), 168 'GetFile': grpc.unary_unary_rpc_method_handler( 169 servicer.GetFile, 170 request_deserializer=files_dot_files__pb2.GetFileRequest.FromString, 171 response_serializer=files_dot_files__pb2.GetFileResponse.SerializeToString, 172 ), 173 'DeleteFile': grpc.unary_unary_rpc_method_handler( 174 servicer.DeleteFile, 175 request_deserializer=files_dot_files__pb2.DeleteFileRequest.FromString, 176 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 177 ), 178 } 179 generic_handler = grpc.method_handlers_generic_handler( 180 'files.Files', rpc_method_handlers) 181 server.add_generic_rpc_handlers((generic_handler,)) 182 server.add_registered_method_handlers('files.Files', rpc_method_handlers) 183 184 185 # This class is part of an EXPERIMENTAL API. 186class Files(object): 187 """Missing associated documentation comment in .proto file.""" 188 189 @staticmethod 190 def StartUpload(request, 191 target, 192 options=(), 193 channel_credentials=None, 194 call_credentials=None, 195 insecure=False, 196 compression=None, 197 wait_for_ready=None, 198 timeout=None, 199 metadata=None): 200 return grpc.experimental.unary_unary( 201 request, 202 target, 203 '/files.Files/StartUpload', 204 files_dot_files__pb2.StartUploadRequest.SerializeToString, 205 files_dot_files__pb2.StartUploadResponse.FromString, 206 options, 207 channel_credentials, 208 insecure, 209 call_credentials, 210 compression, 211 wait_for_ready, 212 timeout, 213 metadata, 214 _registered_method=True) 215 216 @staticmethod 217 def CompleteUpload(request, 218 target, 219 options=(), 220 channel_credentials=None, 221 call_credentials=None, 222 insecure=False, 223 compression=None, 224 wait_for_ready=None, 225 timeout=None, 226 metadata=None): 227 return grpc.experimental.unary_unary( 228 request, 229 target, 230 '/files.Files/CompleteUpload', 231 files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 232 files_dot_files__pb2.CompleteUploadResponse.FromString, 233 options, 234 channel_credentials, 235 insecure, 236 call_credentials, 237 compression, 238 wait_for_ready, 239 timeout, 240 metadata, 241 _registered_method=True) 242 243 @staticmethod 244 def AbortUpload(request, 245 target, 246 options=(), 247 channel_credentials=None, 248 call_credentials=None, 249 insecure=False, 250 compression=None, 251 wait_for_ready=None, 252 timeout=None, 253 metadata=None): 254 return grpc.experimental.unary_unary( 255 request, 256 target, 257 '/files.Files/AbortUpload', 258 files_dot_files__pb2.AbortUploadRequest.SerializeToString, 259 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 260 options, 261 channel_credentials, 262 insecure, 263 call_credentials, 264 compression, 265 wait_for_ready, 266 timeout, 267 metadata, 268 _registered_method=True) 269 270 @staticmethod 271 def MoveUpload(request, 272 target, 273 options=(), 274 channel_credentials=None, 275 call_credentials=None, 276 insecure=False, 277 compression=None, 278 wait_for_ready=None, 279 timeout=None, 280 metadata=None): 281 return grpc.experimental.unary_unary( 282 request, 283 target, 284 '/files.Files/MoveUpload', 285 files_dot_files__pb2.MoveUploadRequest.SerializeToString, 286 files_dot_files__pb2.MoveUploadResponse.FromString, 287 options, 288 channel_credentials, 289 insecure, 290 call_credentials, 291 compression, 292 wait_for_ready, 293 timeout, 294 metadata, 295 _registered_method=True) 296 297 @staticmethod 298 def Upload(request, 299 target, 300 options=(), 301 channel_credentials=None, 302 call_credentials=None, 303 insecure=False, 304 compression=None, 305 wait_for_ready=None, 306 timeout=None, 307 metadata=None): 308 return grpc.experimental.unary_unary( 309 request, 310 target, 311 '/files.Files/Upload', 312 files_dot_files__pb2.UploadRequest.SerializeToString, 313 files_dot_files__pb2.UploadResponse.FromString, 314 options, 315 channel_credentials, 316 insecure, 317 call_credentials, 318 compression, 319 wait_for_ready, 320 timeout, 321 metadata, 322 _registered_method=True) 323 324 @staticmethod 325 def GetFile(request, 326 target, 327 options=(), 328 channel_credentials=None, 329 call_credentials=None, 330 insecure=False, 331 compression=None, 332 wait_for_ready=None, 333 timeout=None, 334 metadata=None): 335 return grpc.experimental.unary_unary( 336 request, 337 target, 338 '/files.Files/GetFile', 339 files_dot_files__pb2.GetFileRequest.SerializeToString, 340 files_dot_files__pb2.GetFileResponse.FromString, 341 options, 342 channel_credentials, 343 insecure, 344 call_credentials, 345 compression, 346 wait_for_ready, 347 timeout, 348 metadata, 349 _registered_method=True) 350 351 @staticmethod 352 def DeleteFile(request, 353 target, 354 options=(), 355 channel_credentials=None, 356 call_credentials=None, 357 insecure=False, 358 compression=None, 359 wait_for_ready=None, 360 timeout=None, 361 metadata=None): 362 return grpc.experimental.unary_unary( 363 request, 364 target, 365 '/files.Files/DeleteFile', 366 files_dot_files__pb2.DeleteFileRequest.SerializeToString, 367 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 368 options, 369 channel_credentials, 370 insecure, 371 call_credentials, 372 compression, 373 wait_for_ready, 374 timeout, 375 metadata, 376 _registered_method=True)
30class FilesStub(object): 31 """Missing associated documentation comment in .proto file.""" 32 33 def __init__(self, channel): 34 """Constructor. 35 36 Args: 37 channel: A grpc.Channel. 38 """ 39 self.StartUpload = channel.unary_unary( 40 '/files.Files/StartUpload', 41 request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString, 42 response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString, 43 _registered_method=True) 44 self.CompleteUpload = channel.unary_unary( 45 '/files.Files/CompleteUpload', 46 request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 47 response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString, 48 _registered_method=True) 49 self.AbortUpload = channel.unary_unary( 50 '/files.Files/AbortUpload', 51 request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString, 52 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 53 _registered_method=True) 54 self.MoveUpload = channel.unary_unary( 55 '/files.Files/MoveUpload', 56 request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString, 57 response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString, 58 _registered_method=True) 59 self.Upload = channel.unary_unary( 60 '/files.Files/Upload', 61 request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString, 62 response_deserializer=files_dot_files__pb2.UploadResponse.FromString, 63 _registered_method=True) 64 self.GetFile = channel.unary_unary( 65 '/files.Files/GetFile', 66 request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString, 67 response_deserializer=files_dot_files__pb2.GetFileResponse.FromString, 68 _registered_method=True) 69 self.DeleteFile = channel.unary_unary( 70 '/files.Files/DeleteFile', 71 request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString, 72 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 73 _registered_method=True)
Missing associated documentation comment in .proto file.
33 def __init__(self, channel): 34 """Constructor. 35 36 Args: 37 channel: A grpc.Channel. 38 """ 39 self.StartUpload = channel.unary_unary( 40 '/files.Files/StartUpload', 41 request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString, 42 response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString, 43 _registered_method=True) 44 self.CompleteUpload = channel.unary_unary( 45 '/files.Files/CompleteUpload', 46 request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 47 response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString, 48 _registered_method=True) 49 self.AbortUpload = channel.unary_unary( 50 '/files.Files/AbortUpload', 51 request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString, 52 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 53 _registered_method=True) 54 self.MoveUpload = channel.unary_unary( 55 '/files.Files/MoveUpload', 56 request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString, 57 response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString, 58 _registered_method=True) 59 self.Upload = channel.unary_unary( 60 '/files.Files/Upload', 61 request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString, 62 response_deserializer=files_dot_files__pb2.UploadResponse.FromString, 63 _registered_method=True) 64 self.GetFile = channel.unary_unary( 65 '/files.Files/GetFile', 66 request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString, 67 response_deserializer=files_dot_files__pb2.GetFileResponse.FromString, 68 _registered_method=True) 69 self.DeleteFile = channel.unary_unary( 70 '/files.Files/DeleteFile', 71 request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString, 72 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 73 _registered_method=True)
Constructor.
Arguments:
- channel: A grpc.Channel.
76class FilesServicer(object): 77 """Missing associated documentation comment in .proto file.""" 78 79 def StartUpload(self, request, context): 80 """StartUpload - инициирует процедуру загрузки файла в файловое хранилище. 81 Используется клиентским приложением для начала загрузки файла 82 Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором 83 обязательные поля Name и Size. 84 Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID. 85 """ 86 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 87 context.set_details('Method not implemented!') 88 raise NotImplementedError('Method not implemented!') 89 90 def CompleteUpload(self, request, context): 91 """CompleteUpload - завершает процедуру загрузку файла 92 Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле 93 Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload` 94 """ 95 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 96 context.set_details('Method not implemented!') 97 raise NotImplementedError('Method not implemented!') 98 99 def AbortUpload(self, request, context): 100 """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища 101 """ 102 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 103 context.set_details('Method not implemented!') 104 raise NotImplementedError('Method not implemented!') 105 106 def MoveUpload(self, request, context): 107 """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения. 108 После перемещение загрузки хранилище выдает новый идентификатор постоянного файла 109 """ 110 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 111 context.set_details('Method not implemented!') 112 raise NotImplementedError('Method not implemented!') 113 114 def Upload(self, request, context): 115 """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL. 116 Завершение загрузки файла осуществляется выполнением POST-запроса 117 """ 118 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 119 context.set_details('Method not implemented!') 120 raise NotImplementedError('Method not implemented!') 121 122 def GetFile(self, request, context): 123 """GetFile - получить информацию о файле (ссылку) по ID 124 """ 125 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 126 context.set_details('Method not implemented!') 127 raise NotImplementedError('Method not implemented!') 128 129 def DeleteFile(self, request, context): 130 """DeleteFile - удаляет файл. Если происходит удаление оригинала, 131 удаляются и все связанные структуры 132 Возможны следующие ситуации: 133 - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы. 134 - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name' 135 - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type' 136 """ 137 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 138 context.set_details('Method not implemented!') 139 raise NotImplementedError('Method not implemented!')
Missing associated documentation comment in .proto file.
79 def StartUpload(self, request, context): 80 """StartUpload - инициирует процедуру загрузки файла в файловое хранилище. 81 Используется клиентским приложением для начала загрузки файла 82 Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором 83 обязательные поля Name и Size. 84 Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID. 85 """ 86 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 87 context.set_details('Method not implemented!') 88 raise NotImplementedError('Method not implemented!')
StartUpload - инициирует процедуру загрузки файла в файловое хранилище.
Используется клиентским приложением для начала загрузки файла
Требуемые параметры: объект MultipartUpload
с вложенным объектом File
, в котором
обязательные поля Name и Size.
Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID.
90 def CompleteUpload(self, request, context): 91 """CompleteUpload - завершает процедуру загрузку файла 92 Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле 93 Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload` 94 """ 95 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 96 context.set_details('Method not implemented!') 97 raise NotImplementedError('Method not implemented!')
CompleteUpload - завершает процедуру загрузку файла
Предполагается, что в объекте, полученном из StartUpload
, клиент должен заполнить поле
Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в CompleteUpload
99 def AbortUpload(self, request, context): 100 """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища 101 """ 102 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 103 context.set_details('Method not implemented!') 104 raise NotImplementedError('Method not implemented!')
AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища
106 def MoveUpload(self, request, context): 107 """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения. 108 После перемещение загрузки хранилище выдает новый идентификатор постоянного файла 109 """ 110 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 111 context.set_details('Method not implemented!') 112 raise NotImplementedError('Method not implemented!')
MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения. После перемещение загрузки хранилище выдает новый идентификатор постоянного файла
114 def Upload(self, request, context): 115 """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL. 116 Завершение загрузки файла осуществляется выполнением POST-запроса 117 """ 118 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 119 context.set_details('Method not implemented!') 120 raise NotImplementedError('Method not implemented!')
Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL. Завершение загрузки файла осуществляется выполнением POST-запроса
122 def GetFile(self, request, context): 123 """GetFile - получить информацию о файле (ссылку) по ID 124 """ 125 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 126 context.set_details('Method not implemented!') 127 raise NotImplementedError('Method not implemented!')
GetFile - получить информацию о файле (ссылку) по ID
129 def DeleteFile(self, request, context): 130 """DeleteFile - удаляет файл. Если происходит удаление оригинала, 131 удаляются и все связанные структуры 132 Возможны следующие ситуации: 133 - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы. 134 - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name' 135 - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type' 136 """ 137 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 138 context.set_details('Method not implemented!') 139 raise NotImplementedError('Method not implemented!')
DeleteFile - удаляет файл. Если происходит удаление оригинала, удаляются и все связанные структуры Возможны следующие ситуации:
- Удаление оригинального файла. Удаляется файл и все связанные с ним файлы.
- Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name'
- Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type'
142def add_FilesServicer_to_server(servicer, server): 143 rpc_method_handlers = { 144 'StartUpload': grpc.unary_unary_rpc_method_handler( 145 servicer.StartUpload, 146 request_deserializer=files_dot_files__pb2.StartUploadRequest.FromString, 147 response_serializer=files_dot_files__pb2.StartUploadResponse.SerializeToString, 148 ), 149 'CompleteUpload': grpc.unary_unary_rpc_method_handler( 150 servicer.CompleteUpload, 151 request_deserializer=files_dot_files__pb2.CompleteUploadRequest.FromString, 152 response_serializer=files_dot_files__pb2.CompleteUploadResponse.SerializeToString, 153 ), 154 'AbortUpload': grpc.unary_unary_rpc_method_handler( 155 servicer.AbortUpload, 156 request_deserializer=files_dot_files__pb2.AbortUploadRequest.FromString, 157 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 158 ), 159 'MoveUpload': grpc.unary_unary_rpc_method_handler( 160 servicer.MoveUpload, 161 request_deserializer=files_dot_files__pb2.MoveUploadRequest.FromString, 162 response_serializer=files_dot_files__pb2.MoveUploadResponse.SerializeToString, 163 ), 164 'Upload': grpc.unary_unary_rpc_method_handler( 165 servicer.Upload, 166 request_deserializer=files_dot_files__pb2.UploadRequest.FromString, 167 response_serializer=files_dot_files__pb2.UploadResponse.SerializeToString, 168 ), 169 'GetFile': grpc.unary_unary_rpc_method_handler( 170 servicer.GetFile, 171 request_deserializer=files_dot_files__pb2.GetFileRequest.FromString, 172 response_serializer=files_dot_files__pb2.GetFileResponse.SerializeToString, 173 ), 174 'DeleteFile': grpc.unary_unary_rpc_method_handler( 175 servicer.DeleteFile, 176 request_deserializer=files_dot_files__pb2.DeleteFileRequest.FromString, 177 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 178 ), 179 } 180 generic_handler = grpc.method_handlers_generic_handler( 181 'files.Files', rpc_method_handlers) 182 server.add_generic_rpc_handlers((generic_handler,)) 183 server.add_registered_method_handlers('files.Files', rpc_method_handlers)
187class Files(object): 188 """Missing associated documentation comment in .proto file.""" 189 190 @staticmethod 191 def StartUpload(request, 192 target, 193 options=(), 194 channel_credentials=None, 195 call_credentials=None, 196 insecure=False, 197 compression=None, 198 wait_for_ready=None, 199 timeout=None, 200 metadata=None): 201 return grpc.experimental.unary_unary( 202 request, 203 target, 204 '/files.Files/StartUpload', 205 files_dot_files__pb2.StartUploadRequest.SerializeToString, 206 files_dot_files__pb2.StartUploadResponse.FromString, 207 options, 208 channel_credentials, 209 insecure, 210 call_credentials, 211 compression, 212 wait_for_ready, 213 timeout, 214 metadata, 215 _registered_method=True) 216 217 @staticmethod 218 def CompleteUpload(request, 219 target, 220 options=(), 221 channel_credentials=None, 222 call_credentials=None, 223 insecure=False, 224 compression=None, 225 wait_for_ready=None, 226 timeout=None, 227 metadata=None): 228 return grpc.experimental.unary_unary( 229 request, 230 target, 231 '/files.Files/CompleteUpload', 232 files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 233 files_dot_files__pb2.CompleteUploadResponse.FromString, 234 options, 235 channel_credentials, 236 insecure, 237 call_credentials, 238 compression, 239 wait_for_ready, 240 timeout, 241 metadata, 242 _registered_method=True) 243 244 @staticmethod 245 def AbortUpload(request, 246 target, 247 options=(), 248 channel_credentials=None, 249 call_credentials=None, 250 insecure=False, 251 compression=None, 252 wait_for_ready=None, 253 timeout=None, 254 metadata=None): 255 return grpc.experimental.unary_unary( 256 request, 257 target, 258 '/files.Files/AbortUpload', 259 files_dot_files__pb2.AbortUploadRequest.SerializeToString, 260 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 261 options, 262 channel_credentials, 263 insecure, 264 call_credentials, 265 compression, 266 wait_for_ready, 267 timeout, 268 metadata, 269 _registered_method=True) 270 271 @staticmethod 272 def MoveUpload(request, 273 target, 274 options=(), 275 channel_credentials=None, 276 call_credentials=None, 277 insecure=False, 278 compression=None, 279 wait_for_ready=None, 280 timeout=None, 281 metadata=None): 282 return grpc.experimental.unary_unary( 283 request, 284 target, 285 '/files.Files/MoveUpload', 286 files_dot_files__pb2.MoveUploadRequest.SerializeToString, 287 files_dot_files__pb2.MoveUploadResponse.FromString, 288 options, 289 channel_credentials, 290 insecure, 291 call_credentials, 292 compression, 293 wait_for_ready, 294 timeout, 295 metadata, 296 _registered_method=True) 297 298 @staticmethod 299 def Upload(request, 300 target, 301 options=(), 302 channel_credentials=None, 303 call_credentials=None, 304 insecure=False, 305 compression=None, 306 wait_for_ready=None, 307 timeout=None, 308 metadata=None): 309 return grpc.experimental.unary_unary( 310 request, 311 target, 312 '/files.Files/Upload', 313 files_dot_files__pb2.UploadRequest.SerializeToString, 314 files_dot_files__pb2.UploadResponse.FromString, 315 options, 316 channel_credentials, 317 insecure, 318 call_credentials, 319 compression, 320 wait_for_ready, 321 timeout, 322 metadata, 323 _registered_method=True) 324 325 @staticmethod 326 def GetFile(request, 327 target, 328 options=(), 329 channel_credentials=None, 330 call_credentials=None, 331 insecure=False, 332 compression=None, 333 wait_for_ready=None, 334 timeout=None, 335 metadata=None): 336 return grpc.experimental.unary_unary( 337 request, 338 target, 339 '/files.Files/GetFile', 340 files_dot_files__pb2.GetFileRequest.SerializeToString, 341 files_dot_files__pb2.GetFileResponse.FromString, 342 options, 343 channel_credentials, 344 insecure, 345 call_credentials, 346 compression, 347 wait_for_ready, 348 timeout, 349 metadata, 350 _registered_method=True) 351 352 @staticmethod 353 def DeleteFile(request, 354 target, 355 options=(), 356 channel_credentials=None, 357 call_credentials=None, 358 insecure=False, 359 compression=None, 360 wait_for_ready=None, 361 timeout=None, 362 metadata=None): 363 return grpc.experimental.unary_unary( 364 request, 365 target, 366 '/files.Files/DeleteFile', 367 files_dot_files__pb2.DeleteFileRequest.SerializeToString, 368 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 369 options, 370 channel_credentials, 371 insecure, 372 call_credentials, 373 compression, 374 wait_for_ready, 375 timeout, 376 metadata, 377 _registered_method=True)
Missing associated documentation comment in .proto file.
190 @staticmethod 191 def StartUpload(request, 192 target, 193 options=(), 194 channel_credentials=None, 195 call_credentials=None, 196 insecure=False, 197 compression=None, 198 wait_for_ready=None, 199 timeout=None, 200 metadata=None): 201 return grpc.experimental.unary_unary( 202 request, 203 target, 204 '/files.Files/StartUpload', 205 files_dot_files__pb2.StartUploadRequest.SerializeToString, 206 files_dot_files__pb2.StartUploadResponse.FromString, 207 options, 208 channel_credentials, 209 insecure, 210 call_credentials, 211 compression, 212 wait_for_ready, 213 timeout, 214 metadata, 215 _registered_method=True)
217 @staticmethod 218 def CompleteUpload(request, 219 target, 220 options=(), 221 channel_credentials=None, 222 call_credentials=None, 223 insecure=False, 224 compression=None, 225 wait_for_ready=None, 226 timeout=None, 227 metadata=None): 228 return grpc.experimental.unary_unary( 229 request, 230 target, 231 '/files.Files/CompleteUpload', 232 files_dot_files__pb2.CompleteUploadRequest.SerializeToString, 233 files_dot_files__pb2.CompleteUploadResponse.FromString, 234 options, 235 channel_credentials, 236 insecure, 237 call_credentials, 238 compression, 239 wait_for_ready, 240 timeout, 241 metadata, 242 _registered_method=True)
244 @staticmethod 245 def AbortUpload(request, 246 target, 247 options=(), 248 channel_credentials=None, 249 call_credentials=None, 250 insecure=False, 251 compression=None, 252 wait_for_ready=None, 253 timeout=None, 254 metadata=None): 255 return grpc.experimental.unary_unary( 256 request, 257 target, 258 '/files.Files/AbortUpload', 259 files_dot_files__pb2.AbortUploadRequest.SerializeToString, 260 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 261 options, 262 channel_credentials, 263 insecure, 264 call_credentials, 265 compression, 266 wait_for_ready, 267 timeout, 268 metadata, 269 _registered_method=True)
271 @staticmethod 272 def MoveUpload(request, 273 target, 274 options=(), 275 channel_credentials=None, 276 call_credentials=None, 277 insecure=False, 278 compression=None, 279 wait_for_ready=None, 280 timeout=None, 281 metadata=None): 282 return grpc.experimental.unary_unary( 283 request, 284 target, 285 '/files.Files/MoveUpload', 286 files_dot_files__pb2.MoveUploadRequest.SerializeToString, 287 files_dot_files__pb2.MoveUploadResponse.FromString, 288 options, 289 channel_credentials, 290 insecure, 291 call_credentials, 292 compression, 293 wait_for_ready, 294 timeout, 295 metadata, 296 _registered_method=True)
298 @staticmethod 299 def Upload(request, 300 target, 301 options=(), 302 channel_credentials=None, 303 call_credentials=None, 304 insecure=False, 305 compression=None, 306 wait_for_ready=None, 307 timeout=None, 308 metadata=None): 309 return grpc.experimental.unary_unary( 310 request, 311 target, 312 '/files.Files/Upload', 313 files_dot_files__pb2.UploadRequest.SerializeToString, 314 files_dot_files__pb2.UploadResponse.FromString, 315 options, 316 channel_credentials, 317 insecure, 318 call_credentials, 319 compression, 320 wait_for_ready, 321 timeout, 322 metadata, 323 _registered_method=True)
325 @staticmethod 326 def GetFile(request, 327 target, 328 options=(), 329 channel_credentials=None, 330 call_credentials=None, 331 insecure=False, 332 compression=None, 333 wait_for_ready=None, 334 timeout=None, 335 metadata=None): 336 return grpc.experimental.unary_unary( 337 request, 338 target, 339 '/files.Files/GetFile', 340 files_dot_files__pb2.GetFileRequest.SerializeToString, 341 files_dot_files__pb2.GetFileResponse.FromString, 342 options, 343 channel_credentials, 344 insecure, 345 call_credentials, 346 compression, 347 wait_for_ready, 348 timeout, 349 metadata, 350 _registered_method=True)
352 @staticmethod 353 def DeleteFile(request, 354 target, 355 options=(), 356 channel_credentials=None, 357 call_credentials=None, 358 insecure=False, 359 compression=None, 360 wait_for_ready=None, 361 timeout=None, 362 metadata=None): 363 return grpc.experimental.unary_unary( 364 request, 365 target, 366 '/files.Files/DeleteFile', 367 files_dot_files__pb2.DeleteFileRequest.SerializeToString, 368 google_dot_protobuf_dot_empty__pb2.Empty.FromString, 369 options, 370 channel_credentials, 371 insecure, 372 call_credentials, 373 compression, 374 wait_for_ready, 375 timeout, 376 metadata, 377 _registered_method=True)