forked from singer-io/singer-python
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy path__init__.py
More file actions
71 lines (64 loc) · 1.22 KB
/
__init__.py
File metadata and controls
71 lines (64 loc) · 1.22 KB
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
from singer import utils
from singer.utils import (
chunk,
load_json,
parse_args,
ratelimit,
strftime,
strptime,
update_state,
)
from singer.logger import (
get_logger,
log_debug,
log_info,
log_warning,
log_error,
log_critical,
log_fatal,
log_exception,
)
from singer.metrics import (
Counter,
Timer,
http_request_timer,
job_timer,
record_counter,
)
from singer.messages import (
ActivateVersionMessage,
Message,
RecordMessage,
SchemaMessage,
StateMessage,
format_message,
parse_message,
write_message,
write_record,
write_records,
write_schema,
write_state,
)
from singer.transform import (
NO_INTEGER_DATETIME_PARSING,
UNIX_SECONDS_INTEGER_DATETIME_PARSING,
UNIX_MILLISECONDS_INTEGER_DATETIME_PARSING,
Transformer,
transform,
_transform_datetime,
resolve_schema_references
)
from singer.catalog import Catalog
from singer.schema import Schema
from singer.bookmarks import (
write_bookmark,
get_bookmark,
set_offset,
clear_offset,
get_offset,
set_currently_syncing,
get_currently_syncing,
)
if __name__ == "__main__":
import doctest
doctest.testmod()