writer.py 481 B

1234567891011121314
  1. # -*- coding:utf-8 -*-
  2. from configparser import ConfigParser
  3. from dw_base.datax.plugins.plugin import Plugin
  4. class Writer(Plugin):
  5. def __init__(self, base_dir: str, config_parser: ConfigParser, start_date: str = None, stop_date=None):
  6. super(Writer, self).__init__(base_dir, config_parser, start_date, stop_date)
  7. self.plugin_type = 'writer'
  8. def load_others(self):
  9. raise NotImplementedError('please implement this method in a specified writer.')