Merge pull request 'v2.2.0' (#35) from v2.2.0 into master

Reviewed-on: #35

pyproject.toml

@@ -19,24 +19,15 @@ classifiers = [
 dependencies = [
     "termcolor","sqlalchemy", "aiosqlite","duckdb-engine",
     "mysql-connector-python","psycopg2-binary","nzpy","pymssql","duckdb-engine","aiosqlite",
-    "typer","pandas","numpy","sqlalchemy","pyarrow",
+    "typer","pandas","numpy","sqlalchemy","pyarrow","smart-open",
     "plugin-ix@git+https://github.com/lnyemba/plugins-ix"
 ]
 [project.optional-dependencies]
 sql         = ["mysql-connector-python","psycopg2-binary","nzpy","pymssql","duckdb-engine","aiosqlite"]
 nosql       = ["pymongo","cloudant"]
-cloud       = ["pandas-gbq","google-cloud-bigquery","google-cloud-bigquery-storage", "databricks-sqlalchemy","pyncclient","boto3","boto","botocore"]
+cloud       = ["boto","boto3","botocore","pyncclient","pandas-gbq","google-cloud-bigquery","google-cloud-bigquery-storage", "databricks-sqlalchemy","pyncclient","boto3","boto","botocore"]
 warehouse   = ["pydrill","pyspark","sqlalchemy_drill"]
-rabbitmq    = ["pika"]
-sqlite      = ["aiosqlite"]
-aws3        = ["boto3","boto","botocore"]
-nextcloud   =  ["pyncclient"]
-mongodb     = ["pymongo"]
-netezza     = ["nzpy"]
-mysql       = ["mysql-connector-python"]
-postgresql  = ["psycopg2-binary"]
-sqlserver   = ["pymssql"]
-http       = ["flask-session"]
+other       = ["pika","flask-session"]
 all         = ["mysql-connector-python","psycopg2-binary","nzpy","pymssql","duckdb-engine","aiosqlite","pymongo","cloudant","pandas-gbq","google-cloud-bigquery","google-cloud-bigquery-storage", "databricks-sqlalchemy","pyncclient","boto3","boto","botocore","pydrill","pyspark","sqlalchemy_drill", "pika","aiosqlite","boto3","boto","botocore", "pyncclient"]
 
 [project.urls]

transport/__init__.py

@@ -18,7 +18,27 @@ Source Code is available under MIT License:
 """
 import numpy as np
 
-from transport import sql, nosql, cloud, other, warehouse
+#from transport import sql, nosql, cloud, other, warehouse
+from transport import sql
+try:
+    from transport import  nosql
+except Exception as e:
+    nosql = {}
+try:
+    from transport import  cloud
+except Exception as e:
+    cloud = {}
+try:
+    from transport import  warehouse
+except Exception as e:
+    warehouse = {}
+try:
+    from transport import  other
+except Exception as e:
+    other = {}
+
+
+
 import pandas as pd
 import json
 import os
@@ -35,7 +55,7 @@ def init():
     global PROVIDERS
     for _module in [cloud,sql,nosql,other,warehouse] :
         for _provider_name in dir(_module) :
-            if _provider_name.startswith('__') or _provider_name == 'common':
+            if _provider_name.startswith('__') or _provider_name == 'common' or type(_module) in [None,str,dict]:
                 continue
             PROVIDERS[_provider_name] = {'module':getattr(_module,_provider_name),'type':_module.__name__}
     #