airbyte_cdk.connector_builder.models 

 1#
 2# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 3#
 4
 5from dataclasses import dataclass
 6from typing import Any, Dict, List, Optional
 7
 8
 9@dataclass
10class HttpResponse:
11    status: int
12    body: Optional[str] = None
13    headers: Optional[Dict[str, Any]] = None
14
15
16@dataclass
17class HttpRequest:
18    url: str
19    headers: Optional[Dict[str, Any]]
20    http_method: str
21    body: Optional[str] = None
22
23
24@dataclass
25class LogMessage:
26    message: str
27    level: str
28    internal_message: Optional[str] = None
29    stacktrace: Optional[str] = None
30
31
32@dataclass
33class AuxiliaryRequest:
34    title: str
35    type: str
36    description: str
37    request: HttpRequest
38    response: HttpResponse
39
40
41@dataclass
42class StreamReadPages:
43    records: List[object]
44    request: Optional[HttpRequest] = None
45    response: Optional[HttpResponse] = None
46
47
48@dataclass
49class StreamReadSlices:
50    pages: List[StreamReadPages]
51    slice_descriptor: Optional[Dict[str, Any]]
52    state: Optional[List[Dict[str, Any]]] = None
53    auxiliary_requests: Optional[List[AuxiliaryRequest]] = None
54
55
56@dataclass
57class StreamRead(object):
58    logs: List[LogMessage]
59    slices: List[StreamReadSlices]
60    test_read_limit_reached: bool
61    auxiliary_requests: List[AuxiliaryRequest]
62    inferred_schema: Optional[Dict[str, Any]]
63    inferred_datetime_formats: Optional[Dict[str, str]]
64    latest_config_update: Optional[Dict[str, Any]]
65
66
67@dataclass
68class StreamReadRequestBody:
69    manifest: Dict[str, Any]
70    stream: str
71    config: Dict[str, Any]
72    state: Optional[Dict[str, Any]]
73    record_limit: Optional[int]
@dataclass
class HttpResponse: 
10@dataclass
11class HttpResponse:
12    status: int
13    body: Optional[str] = None
14    headers: Optional[Dict[str, Any]] = None
HttpResponse( status: int, body: Optional[str] = None, headers: Optional[Dict[str, Any]] = None)
status: int
body: Optional[str] = None
headers: Optional[Dict[str, Any]] = None
@dataclass
class HttpRequest: 
17@dataclass
18class HttpRequest:
19    url: str
20    headers: Optional[Dict[str, Any]]
21    http_method: str
22    body: Optional[str] = None
HttpRequest( url: str, headers: Optional[Dict[str, Any]], http_method: str, body: Optional[str] = None)
url: str
headers: Optional[Dict[str, Any]]
http_method: str
body: Optional[str] = None
@dataclass
class LogMessage: 
25@dataclass
26class LogMessage:
27    message: str
28    level: str
29    internal_message: Optional[str] = None
30    stacktrace: Optional[str] = None
LogMessage( message: str, level: str, internal_message: Optional[str] = None, stacktrace: Optional[str] = None)
message: str
level: str
internal_message: Optional[str] = None
stacktrace: Optional[str] = None
@dataclass
class AuxiliaryRequest: 
33@dataclass
34class AuxiliaryRequest:
35    title: str
36    type: str
37    description: str
38    request: HttpRequest
39    response: HttpResponse
AuxiliaryRequest( title: str, type: str, description: str, request: HttpRequest, response: HttpResponse)
title: str
type: str
description: str
request: HttpRequest
response: HttpResponse
@dataclass
class StreamReadPages: 
42@dataclass
43class StreamReadPages:
44    records: List[object]
45    request: Optional[HttpRequest] = None
46    response: Optional[HttpResponse] = None
StreamReadPages( records: List[object], request: Optional[HttpRequest] = None, response: Optional[HttpResponse] = None)
records: List[object]
request: Optional[HttpRequest] = None
response: Optional[HttpResponse] = None
@dataclass
class StreamReadSlices: 
49@dataclass
50class StreamReadSlices:
51    pages: List[StreamReadPages]
52    slice_descriptor: Optional[Dict[str, Any]]
53    state: Optional[List[Dict[str, Any]]] = None
54    auxiliary_requests: Optional[List[AuxiliaryRequest]] = None
StreamReadSlices( pages: List[StreamReadPages], slice_descriptor: Optional[Dict[str, Any]], state: Optional[List[Dict[str, Any]]] = None, auxiliary_requests: Optional[List[AuxiliaryRequest]] = None)
pages: List[StreamReadPages]
slice_descriptor: Optional[Dict[str, Any]]
state: Optional[List[Dict[str, Any]]] = None
auxiliary_requests: Optional[List[AuxiliaryRequest]] = None
@dataclass
class StreamRead: 
57@dataclass
58class StreamRead(object):
59    logs: List[LogMessage]
60    slices: List[StreamReadSlices]
61    test_read_limit_reached: bool
62    auxiliary_requests: List[AuxiliaryRequest]
63    inferred_schema: Optional[Dict[str, Any]]
64    inferred_datetime_formats: Optional[Dict[str, str]]
65    latest_config_update: Optional[Dict[str, Any]]
StreamRead( logs: List[LogMessage], slices: List[StreamReadSlices], test_read_limit_reached: bool, auxiliary_requests: List[AuxiliaryRequest], inferred_schema: Optional[Dict[str, Any]], inferred_datetime_formats: Optional[Dict[str, str]], latest_config_update: Optional[Dict[str, Any]])
logs: List[LogMessage]
slices: List[StreamReadSlices]
test_read_limit_reached: bool
auxiliary_requests: List[AuxiliaryRequest]
inferred_schema: Optional[Dict[str, Any]]
inferred_datetime_formats: Optional[Dict[str, str]]
latest_config_update: Optional[Dict[str, Any]]
@dataclass
class StreamReadRequestBody: 
68@dataclass
69class StreamReadRequestBody:
70    manifest: Dict[str, Any]
71    stream: str
72    config: Dict[str, Any]
73    state: Optional[Dict[str, Any]]
74    record_limit: Optional[int]
StreamReadRequestBody( manifest: Dict[str, Any], stream: str, config: Dict[str, Any], state: Optional[Dict[str, Any]], record_limit: Optional[int])
manifest: Dict[str, Any]
stream: str
config: Dict[str, Any]
state: Optional[Dict[str, Any]]
record_limit: Optional[int]