beam-mysql-connector

Name	beam-mysql-connector JSON
Version	1.8.6 JSON
	download
home_page	https://github.com/esakik/beam-mysql-connector
Summary	Apache Beam I/O connector designed for accessing MySQL databases.
upload_time	2024-07-15 09:39:06
maintainer	None
docs_url	None
author	esakik
requires_python	<3.12,>=3.8
license	MIT
keywords	apache beam mysql connector
VCS
bugtrack_url
requirements	No requirements were recorded.
Travis-CI	No Travis.
coveralls test coverage	No coveralls.

            # Beam - MySQL Connector
[![PyPI version](https://badge.fury.io/py/beam-mysql-connector.svg)](https://badge.fury.io/py/beam-mysql-connector)
![PyPI - Python Version](https://img.shields.io/pypi/pyversions/beam-mysql-connector)
[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)

Beam - MySQL Connector is an io connector of [Apache Beam](https://beam.apache.org/) to access MySQL databases.

## Installation
```bash
pip install beam-mysql-connector
```

## Getting Started
- Read From MySQL
```Python
from beam_mysql.connector import splitters
from beam_mysql.connector.io import ReadFromMySQL


read_from_mysql = ReadFromMySQL(
        query="SELECT * FROM test_db.tests;",
        host="localhost",
        database="test_db",
        user="test",
        password="test",
        port=3306,
        splitter=splitters.NoSplitter()  # you can select how to split query for performance
)
```

- Write To MySQL
```Python
from beam_mysql.connector.io import WriteToMySQL


write_to_mysql = WriteToMySQL(
        host="localhost",
        database="test_db",
        table="tests",
        user="test",
        password="test",
        port=3306,
        batch_size=1000,
)
```

## License
MIT License. Please refer to the [LICENSE.txt](https://github.com/esaki01/beam-mysql-connector/blob/master/LICENSE.txt), for further details.

            

Raw data

            {
    "_id": null,
    "home_page": "https://github.com/esakik/beam-mysql-connector",
    "name": "beam-mysql-connector",
    "maintainer": null,
    "docs_url": null,
    "requires_python": "<3.12,>=3.8",
    "maintainer_email": null,
    "keywords": "apache beam mysql connector",
    "author": "esakik",
    "author_email": "esakik.dev@gmail.com",
    "download_url": "https://files.pythonhosted.org/packages/c2/78/83c065d6ec06218bdc03084a36f0a294e9ee3fdccf5fb0dcca50c1878e77/beam_mysql_connector-1.8.6.tar.gz",
    "platform": null,
    "description": "# Beam - MySQL Connector\n[![PyPI version](https://badge.fury.io/py/beam-mysql-connector.svg)](https://badge.fury.io/py/beam-mysql-connector)\n![PyPI - Python Version](https://img.shields.io/pypi/pyversions/beam-mysql-connector)\n[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)\n\nBeam - MySQL Connector is an io connector of [Apache Beam](https://beam.apache.org/) to access MySQL databases.\n\n## Installation\n```bash\npip install beam-mysql-connector\n```\n\n## Getting Started\n- Read From MySQL\n```Python\nfrom beam_mysql.connector import splitters\nfrom beam_mysql.connector.io import ReadFromMySQL\n\n\nread_from_mysql = ReadFromMySQL(\n        query=\"SELECT * FROM test_db.tests;\",\n        host=\"localhost\",\n        database=\"test_db\",\n        user=\"test\",\n        password=\"test\",\n        port=3306,\n        splitter=splitters.NoSplitter()  # you can select how to split query for performance\n)\n```\n\n- Write To MySQL\n```Python\nfrom beam_mysql.connector.io import WriteToMySQL\n\n\nwrite_to_mysql = WriteToMySQL(\n        host=\"localhost\",\n        database=\"test_db\",\n        table=\"tests\",\n        user=\"test\",\n        password=\"test\",\n        port=3306,\n        batch_size=1000,\n)\n```\n\n## License\nMIT License. Please refer to the [LICENSE.txt](https://github.com/esaki01/beam-mysql-connector/blob/master/LICENSE.txt), for further details.\n",
    "bugtrack_url": null,
    "license": "MIT",
    "summary": "Apache Beam I/O connector designed for accessing MySQL databases.",
    "version": "1.8.6",
    "project_urls": {
        "Download": "https://pypi.python.org/pypi/beam-mysql-connector",
        "Homepage": "https://github.com/esakik/beam-mysql-connector"
    },
    "split_keywords": [
        "apache",
        "beam",
        "mysql",
        "connector"
    ],
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "blake2b_256": "c27883c065d6ec06218bdc03084a36f0a294e9ee3fdccf5fb0dcca50c1878e77",
                "md5": "bb94a33ba4b700a8ce5c0b262d5efa5c",
                "sha256": "21f0ad08e561883822e6f68e5b85b16786392fa4289451465484f72c1f03d9d5"
            },
            "downloads": -1,
            "filename": "beam_mysql_connector-1.8.6.tar.gz",
            "has_sig": false,
            "md5_digest": "bb94a33ba4b700a8ce5c0b262d5efa5c",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": "<3.12,>=3.8",
            "size": 9278,
            "upload_time": "2024-07-15T09:39:06",
            "upload_time_iso_8601": "2024-07-15T09:39:06.444426Z",
            "url": "https://files.pythonhosted.org/packages/c2/78/83c065d6ec06218bdc03084a36f0a294e9ee3fdccf5fb0dcca50c1878e77/beam_mysql_connector-1.8.6.tar.gz",
            "yanked": false,
            "yanked_reason": null
        }
    ],
    "upload_time": "2024-07-15 09:39:06",
    "github": true,
    "gitlab": false,
    "bitbucket": false,
    "codeberg": false,
    "github_user": "esakik",
    "github_project": "beam-mysql-connector",
    "travis_ci": false,
    "coveralls": false,
    "github_actions": false,
    "lcname": "beam-mysql-connector"
}