v2.2.0 #2

Merged
steve merged 2 commits from v2.2.0 into main 3 weeks ago

@ -4,23 +4,34 @@ This project implements an abstraction of objects that can have access to a vari
# Why Use Data-Transport ? # Why Use Data-Transport ?
Data transport is a simple framework that: Data transport is a simple framework that enables read/write to multiple databases or technologies that can hold data. In using **data-transport**, you are able to:
- easy to install & modify (open-source)
- enables access to multiple database technologies (pandas, SQLAlchemy)
- enables notebook sharing without exposing database credential.
- supports pre/post processing specifications (pipeline)
- Enjoy the simplicity of **data-transport** because it leverages SQLAlchemy & Pandas data-frames.
- Share notebooks and code without having to disclosing database credentials.
- Seamlessly and consistently access to multiple database technologies at no cost
- No need to worry about accidental writes to a database leading to inconsistent data
- Implement consistent pre and post processing as a pipeline i.e aggregation of functions
- **data-transport** is open-source under MIT License https://github.com/lnyemba/data-transport
## Installation ## Installation
Within the virtual environment perform the following : Within the virtual environment perform the following, the options for installation are:
pip install git+https://github.com/lnyemba/data-transport.git **sql** - by default postgresql, mysql, sqlserver, sqlite3+, duckdb
Options to install components in square brackets pip install data-transport[cloud,nosql,other,all]git+https://github.com/lnyemba/data-transport.git
pip install data-transport[nosql,cloud,warehouse,all]@git+https://github.com/lnyemba/data-transport.git Options to install components in square brackets, these components are
**warehouse** - Apache Iceberg, Apache Drill
**cloud**  - to support nextcloud, s3
**nosql** - support for mongodb, couchdb
**other**  - support for files, rabbitmq, http
pip install data-transport[nosql,cloud,warehouse,all]@git+https://github.com/lnyemba/data-transport.git
## Additional features ## Additional features
@ -28,7 +39,6 @@ Options to install components in square brackets
- CLI interface to add to registry, run ETL - CLI interface to add to registry, run ETL
- scales and integrates into shared environments like apache zeppelin; jupyterhub; SageMaker; ... - scales and integrates into shared environments like apache zeppelin; jupyterhub; SageMaker; ...
## Learn More ## Learn More
We have available notebooks with sample code to read/write against mongodb, couchdb, Netezza, PostgreSQL, Google Bigquery, Databricks, Microsoft SQL Server, MySQL ... Visit [data-transport homepage](https://healthcareio.the-phi.com/data-transport) We have available notebooks with sample code to read/write against mongodb, couchdb, Netezza, PostgreSQL, Google Bigquery, Databricks, Microsoft SQL Server, MySQL ... Visit [data-transport homepage](https://healthcareio.the-phi.com/data-transport)

@ -178,7 +178,17 @@ def register (label:Annotated[str,typer.Argument(help="unique label that will be
_msg = f"""{TIMES_MARK} {e}""" _msg = f"""{TIMES_MARK} {e}"""
print (_msg) print (_msg)
pass @app_r.command(name="list")
def register_list ():
"""
This function will list existing registry entries and basic information {label,vendor}
"""
# print (transport.registry.DATA)
_reg = transport.registry.DATA
_data = [{'label':key,'provider':_reg[key]['provider']} for key in _reg if 'provider' in _reg[key]]
_data = pd.DataFrame(_data)
print (_data)
@app_x.command(name='add') @app_x.command(name='add')
def register_plugs ( def register_plugs (
alias:Annotated[str,typer.Argument(help="unique function name within a file")], alias:Annotated[str,typer.Argument(help="unique function name within a file")],

@ -42,11 +42,11 @@ zip-safe = false
script-files = ["bin/transport","bin/transport.cmd"] script-files = ["bin/transport","bin/transport.cmd"]
[tool.setuptools.packages.find] [tool.setuptools.packages.find]
include = ["info","info.*", "transport", "transport.*"] include = [ "transport", "transport.*"]
[tool.setuptools.dynamic] [tool.setuptools.dynamic]
version = {attr = "info.__version__"} version = {attr = "transport.info.__version__"}
#authors = {attr = "meta.__author__"} #authors = {attr = "transport.__author__"}
# If you have a info.py file, you might also want to include the author dynamically: # If you have a info.py file, you might also want to include the author dynamically:
# [tool.setuptools.dynamic] # [tool.setuptools.dynamic]

@ -42,7 +42,7 @@ except Exception as e:
import pandas as pd import pandas as pd
import json import json
import os import os
from info import __version__,__author__,__email__,__license__,__app_name__,__whatsnew__,__edition__ from transport.info import __version__,__author__,__email__,__license__,__app_name__,__whatsnew__,__edition__
from transport.iowrapper import IWriter, IReader, IETL from transport.iowrapper import IWriter, IReader, IETL
from transport.plugins import PluginLoader from transport.plugins import PluginLoader
from transport import providers from transport import providers

@ -0,0 +1,23 @@
__app_name__ = 'data-transport'
__author__ = 'The Phi Technology'
__version__= '2.2.30'
__email__ = "info@the-phi.com"
__edition__= 'community'
__license__=f"""
Copyright 2010 - 2024, Steve L. Nyemba
Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the Software), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED AS IS, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
"""
__whatsnew__=f"""version {__version__},
1. Added support for read/write logs as well as plugins (when applied)
2. Bug fix with duckdb (adding readonly) for readers because there are issues with threads & processes
3. support for streaming data, important to use this with large volumes of data
"""

@ -1,6 +1,6 @@
import os import os
import json import json
from info import __version__ from transport.info import __version__
import copy import copy
import transport import transport
import importlib import importlib

Loading…
Cancel
Save