{
    "info": {
        "author": "Deepak Verma",
        "author_email": "yesdeepakverma@gmail.com",
        "bugtrack_url": null,
        "classifiers": [
            "Intended Audience :: Developers",
            "License :: OSI Approved :: MIT License",
            "Operating System :: OS Independent",
            "Programming Language :: Python :: 2.7",
            "Programming Language :: Python :: 3"
        ],
        "description": "## pysql-beam\n\n### This package is still under development but has been used in few projects in production. This has been tested with dataflow Runner and Direct runner\n\nThis package aim to provide Apache_beam io connector for MySQL and Postgres database.\n\n\nThis package provides apache beam io connector for postgres db and mysql db.\nThis package wil aim to be pure python implementation for both io connector\n\nFYI: This does not uses any jdbc or odbc connector\n\nRequirements:\n\n    1. Python>=2.7 or python>= 3.5\n    2. Apache beam >= 2.10\n    3. pymysql[rsa]\n    4. psycopg2-binary\n\n\nInstallation:\n\n    1. pip install git+git@github.com:MediaAgility/pysql-beam.git\n\n\nCurrent functionality:\n\n    1. Read from MySQL database by passing either table name or sql query\n    2. Read from Postgres database by passing either table name or sql query\n\n\nReference Guide:\n\n1. Java IO connector for the same:\n    https://github.com/spotify/dbeam\n\n2. How to write io connector for Apache Beam:\n    https://beam.apache.org/documentation/io/developing-io-overview/\n\n    https://beam.apache.org/documentation/io/developing-io-python/\n\nUsage Guide:\n```\nfrom pysql_beam.sql_io.sql import ReadFromSQL\n\n....\nReadFromSQL(host=self.options.host, port=self.options.port,\n        username=self.options.username, password=self.options.password,\n        databse=self.options.database,\n        query=self.options.source_query,\n        wrapper=PostgresWrapper,\n        batch=100000)\n\n```\nExamples:\n\n    For mysql:\n    `python cloud_sql_to_file.py --host localhost --port 3306 --database SECRET_DATABASE --username SECRET_USER --password SECRET_PASSWORD --table YOUR_TABLE --output YOUR_OUTPUT_FLLE`\n\n    For postgres:\n    `python cloud_sql_to_file.py --host localhost --port 5432 --database SECRET_DATABASE --username SECRET_USER --password SECRET_PASSWORD --table YOUR_TABLE --output YOUR_OUTPUT_FLLE`\n\n\ncontribution:\n    You can contribute to this package by raising bugs or sending pull requests\n\n\n",
        "description_content_type": "text/markdown",
        "docs_url": null,
        "download_url": "",
        "downloads": {
            "last_day": -1,
            "last_month": -1,
            "last_week": -1
        },
        "home_page": "https://bitbucket.org/dverma90/pysql-beam",
        "keywords": "apache-beam,mysql,postgres,python,io,source,sink,read,write,database",
        "license": "",
        "maintainer": "",
        "maintainer_email": "",
        "name": "pysql-beam",
        "package_url": "https://pypi.org/project/pysql-beam/",
        "platform": "",
        "project_url": "https://pypi.org/project/pysql-beam/",
        "project_urls": {
            "Homepage": "https://bitbucket.org/dverma90/pysql-beam"
        },
        "release_url": "https://pypi.org/project/pysql-beam/0.2/",
        "requires_dist": [
            "apache-beam (>=2.10<=2.12.0)",
            "psycopg2-binary (==2.8.2)",
            "pymysql[rsa] (==0.9.3)",
            "requests (>=2.22.0)"
        ],
        "requires_python": "",
        "summary": "Apache beam mysql and postgres io connector in pure python",
        "version": "0.2"
    },
    "last_serial": 5779518,
    "releases": {
        "0.2": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "32397825cdf7f228f1e027d49eaf7667",
                    "sha256": "7875d9552c67228945a1eed3b47b3fe1dca77444c8a543b0aee0c50cfe3768e0"
                },
                "downloads": -1,
                "filename": "pysql_beam-0.2-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "32397825cdf7f228f1e027d49eaf7667",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": null,
                "size": 17322,
                "upload_time": "2019-09-04T06:26:12",
                "url": "https://files.pythonhosted.org/packages/cb/bc/ac9e6b9c8887045f71c3857407c38d7b888a51bf1e6afaba9bd6d670165a/pysql_beam-0.2-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "c8dfe1e10f33dd020a6e384450b0fcae",
                    "sha256": "ec887acb65104f44e990710d78b1222a144210d651dcabca0a6bdb1cd6eefcee"
                },
                "downloads": -1,
                "filename": "pysql-beam-0.2.tar.gz",
                "has_sig": false,
                "md5_digest": "c8dfe1e10f33dd020a6e384450b0fcae",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 13913,
                "upload_time": "2019-09-04T06:26:14",
                "url": "https://files.pythonhosted.org/packages/02/e6/0455b9e8af19df175e966dbe6bac01232a3a742e4732a73b8c1345330e4c/pysql-beam-0.2.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "32397825cdf7f228f1e027d49eaf7667",
                "sha256": "7875d9552c67228945a1eed3b47b3fe1dca77444c8a543b0aee0c50cfe3768e0"
            },
            "downloads": -1,
            "filename": "pysql_beam-0.2-py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "32397825cdf7f228f1e027d49eaf7667",
            "packagetype": "bdist_wheel",
            "python_version": "py3",
            "requires_python": null,
            "size": 17322,
            "upload_time": "2019-09-04T06:26:12",
            "url": "https://files.pythonhosted.org/packages/cb/bc/ac9e6b9c8887045f71c3857407c38d7b888a51bf1e6afaba9bd6d670165a/pysql_beam-0.2-py3-none-any.whl"
        },
        {
            "comment_text": "",
            "digests": {
                "md5": "c8dfe1e10f33dd020a6e384450b0fcae",
                "sha256": "ec887acb65104f44e990710d78b1222a144210d651dcabca0a6bdb1cd6eefcee"
            },
            "downloads": -1,
            "filename": "pysql-beam-0.2.tar.gz",
            "has_sig": false,
            "md5_digest": "c8dfe1e10f33dd020a6e384450b0fcae",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": null,
            "size": 13913,
            "upload_time": "2019-09-04T06:26:14",
            "url": "https://files.pythonhosted.org/packages/02/e6/0455b9e8af19df175e966dbe6bac01232a3a742e4732a73b8c1345330e4c/pysql-beam-0.2.tar.gz"
        }
    ]
}