Skip to content

Commit

Permalink
Merge pull request #12 from thombashi/develop
Browse files Browse the repository at this point in the history
Add log messages
  • Loading branch information
thombashi committed Sep 10, 2016
2 parents f44bdfb + adf895a commit 4962cf3
Show file tree
Hide file tree
Showing 6 changed files with 73 additions and 15 deletions.
1 change: 1 addition & 0 deletions MANIFEST.in
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
include docs/pages/introduction/summary.txt
include LICENSE
include README.rst
include setup.cfg
Expand Down
2 changes: 2 additions & 0 deletions requirements/docs_requirements.txt
Original file line number Diff line number Diff line change
@@ -1 +1,3 @@
readmemaker
sphinx_rtd_theme
Sphinx
3 changes: 2 additions & 1 deletion requirements/requirements.txt
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
click
DataProperty>=0.8.1
logbook
path.py
SimpleSQLite>=0.4.6
SimpleSQLite>=0.4.8
4 changes: 2 additions & 2 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@

REQUIREMENT_DIR = "requirements"

needs_pytest = set(['pytest', 'test', 'ptr']).intersection(sys.argv)
pytest_runner = ['pytest-runner'] if needs_pytest else []
needs_pytest = set(["pytest", "test", "ptr"]).intersection(sys.argv)
pytest_runner = ["pytest-runner"] if needs_pytest else []


with open("README.rst") as fp:
Expand Down
2 changes: 1 addition & 1 deletion sqlitebiter/__init__.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
VERSION = "0.1.5"
VERSION = "0.1.6"
76 changes: 65 additions & 11 deletions sqlitebiter/sqlitebiter.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,15 +12,23 @@

import click
import dataproperty
import logbook
import path
import simplesqlite
from simplesqlite.loader import ValidationError
from simplesqlite.loader import InvalidDataError
from simplesqlite.loader import OpenError

from ._counter import ResultCounter


CONTEXT_SETTINGS = dict(help_option_names=["-h", "--help"])
CONTEXT_SETTINGS = dict(
help_option_names=["-h", "--help"],
obj={},
)

handler = logbook.StderrHandler()
handler.push_application()


class LoaderNotFound(Exception):
Expand All @@ -31,7 +39,7 @@ class LoaderFactory(object):
LoaderTuple = collections.namedtuple(
"LoaderTuple", "filename_regexp loader")

LOADERTUPLE_LIST = [
__LOADERTUPLE_LIST = [
LoaderTuple(
re.compile("[\.]csv$"),
simplesqlite.loader.CsvTableFileLoader()),
Expand All @@ -45,7 +53,7 @@ class LoaderFactory(object):

@classmethod
def get_loader(cls, file_path):
for loadertuple in cls.LOADERTUPLE_LIST:
for loadertuple in cls.__LOADERTUPLE_LIST:
if loadertuple.filename_regexp.search(file_path) is None:
continue

Expand All @@ -65,27 +73,52 @@ def create_database(database_path):
return simplesqlite.SimpleSQLite(db_path, "w")


def _setup_logger_from_context(ctx, logger):
log_level = ctx.obj.get("LOG_LEVEL")
if log_level == logbook.NOTSET:
logger.disable()
elif log_level is None:
log_level = logbook.INFO
logger.level = log_level


def _get_format_type_from_path(file_path):
return file_path.ext.lstrip(".")


@click.group(context_settings=CONTEXT_SETTINGS)
@click.version_option()
def cmd():
pass
@click.option(
"--debug", "log_level", flag_value=logbook.DEBUG,
help="for debug print.")
@click.option(
"--quiet", "log_level", flag_value=logbook.NOTSET,
help="suppress execution log messages.")
@click.pass_context
def cmd(ctx, log_level):
ctx.obj["LOG_LEVEL"] = log_level


@cmd.command()
@click.argument("files", type=str, nargs=-1)
@click.option(
"-o", "--output-path", default="out.sqlite",
help="Output path of the SQLite database file")
def file(files, output_path):
@click.pass_context
def file(ctx, files, output_path):
"""
Convert CSV/JSON/Excel file(s) to a SQLite database file.
"""

con = create_database(output_path)
result_counter = ResultCounter()

logger = logbook.Logger("sqlitebiter")
_setup_logger_from_context(ctx, logger)

for file_path in files:
if not path.Path(file_path).isfile():
file_path = path.Path(file_path)
if not file_path.isfile():
continue

try:
Expand All @@ -101,10 +134,20 @@ def file(files, output_path):
try:
con.create_table_from_tabledata(tabledata)
result_counter.inc_success()
except (ValueError, IOError):
except (ValueError, IOError) as e:
logger.debug(
"path={:s}, message={:s}".format(file_path, e))
result_counter.inc_fail()
continue
except (ValidationError, InvalidDataError):
except ValidationError as e:
logger.error(
"invalid {:s} data format: path={:s}, message={:s}".format(
_get_format_type_from_path(file_path), file_path, str(e)))
result_counter.inc_fail()
except InvalidDataError as e:
logger.error(
"invalid {:s} data: path={:s}, message={:s}".format(
_get_format_type_from_path(file_path), file_path, str(e)))
result_counter.inc_fail()

sys.exit(result_counter.get_return_code())
Expand All @@ -118,7 +161,8 @@ def file(files, output_path):
@click.option(
"-o", "--output-path", default="out.sqlite",
help="output path of the SQLite database file")
def gs(credentials, title, output_path):
@click.pass_context
def gs(ctx, credentials, title, output_path):
"""
Convert Google Sheets to a SQLite database file.
Expand All @@ -129,6 +173,9 @@ def gs(credentials, title, output_path):
con = create_database(output_path)
result_counter = ResultCounter()

logger = logbook.Logger("sqlitebiter gs")
_setup_logger_from_context(ctx, logger)

loader = simplesqlite.loader.GoogleSheetsTableLoader()
loader.source = credentials
loader.title = title
Expand All @@ -143,7 +190,14 @@ def gs(credentials, title, output_path):
result_counter.inc_success()
except (ValidationError, InvalidDataError):
result_counter.inc_fail()
except (ValidationError, InvalidDataError):
except OpenError as e:
logger.error(e)
except AttributeError:
logger.error("invalid credentials data: path={:s}".format(credentials))
except (ValidationError, InvalidDataError) as e:
logger.error(
"invalid credentials data: path={:s}, message={:s}".format(
credentials, str(e)))
result_counter.inc_fail()

sys.exit(result_counter.get_return_code())
Expand Down

0 comments on commit 4962cf3

Please sign in to comment.