{
    "info": {
        "author": "Antonio Di Mariano",
        "author_email": "antonio.dimariano@gmail.com",
        "bugtrack_url": null,
        "classifiers": [
            "License :: OSI Approved :: MIT License",
            "Operating System :: OS Independent",
            "Programming Language :: Python :: 3"
        ],
        "description": "# Messaging Layer for Microservices \n\n\n\n![](http://www.italiamappe.it/mappa/ImmaginiVetrine/0000106274/Immagine1lrg.jpg)\n\n\n```json\n     _ _          _       _                     \n    | (_)        | |     (_)                    \n  __| |_ ___  ___| | __ _ _ _ __ ___   ___ _ __ \n / _` | / __|/ __| |/ _` | | '_ ` _ \\ / _ \\ '__|\n| (_| | \\__ \\ (__| | (_| | | | | | | |  __/ |   \n \\__,_|_|___/\\___|_|\\__,_|_|_| |_| |_|\\___|_|   \n\n\n```\n\nThis service is in his early age. **DO NOT USE in production** or if you want to, please be aware you are going to use a piece of code which probably will be\nchanged or improved ( and not necessarily in this order) soon and very often. You have been warned!\nThis service requires at least another service listening to a few KAFKA topics.\n\n# Service description\n\n\nThis service provides microservices with an universal communication layer based on KAFKA messages.\nIt provides two kind of Producer. One based on KAFKA and the other one based on the Confluent KAFKA version. \n\n\n\n# Required ENV variables \n\n* brokers=mybroker1:9093,mybroker2:9093,mybroker3:9093\n* monitoring_topic=tcservicesmonitor\n\nIf you are using AVRO you must have \n* schema_registry=https://my_avro_schema_registry:8081\n\n\n# How to use it \n\n### PLAIN TEXT connection\n\n```python\nfrom messaging_middleware.avro_communication_layer.Producer import Producer\nproducer = Producer(bootstrap_servers=\"your broker list here\",\n                                 schema_reqistry_url=\"your schema registry here\",topic='mytopic')\n\n\nproducer.produce_message(\n            value={your json message here},\n            key={your key schema here}, callback=my_callback_function)\n\n\n\n```\n### SSL configuration \n\n\nin order to connect to brokers using the SSL protocol, we need to pass the following kwargs to consumers/producers configuration \n\n\n```python\nfrom messaging_middleware.avro_communication_layer.Consumer import Consumer as AvroConsumer\nfrom messaging_middleware.avro_communication_layer.Producer import Producer as AvroProducer\n\nif __name__ == \"__main__\":\n    c = AvroConsumer(\n        bootstrap_servers=\"sslbroker:29080\",\n        security_protocoll='ssl', consumer_topic='my-topic')\n\n    p = AvroProducer(\n        bootstrap_servers=\"sslbroker:29080\",\n        security_protocoll='ssl', topic='my-topic')\n```\n\n\n## Integrated Logging System \n\nBy default, the Logger is connected to the following ENV variables \n\n* brokers=mybroker:202021,mybroker2:202019\n* schema_registry=\"https://sksk:8081\"\n* monitoring_topic=tcservicesmonitor\n\n```python\nfrom messaging_middleware.utils.logger import Logger\n\nlogger = Logger(ssl=1) \nlogger = Logger()  # no ssl\n\n\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": "",
        "keywords": "",
        "license": "",
        "maintainer": "",
        "maintainer_email": "",
        "name": "microservices-messaging-layer",
        "package_url": "https://pypi.org/project/microservices-messaging-layer/",
        "platform": "",
        "project_url": "https://pypi.org/project/microservices-messaging-layer/",
        "project_urls": null,
        "release_url": "https://pypi.org/project/microservices-messaging-layer/1.0.17/",
        "requires_dist": [
            "avro-python3",
            "kafka",
            "requests",
            "confluent-kafka"
        ],
        "requires_python": "~=3.6",
        "summary": "Messaging Communication Layer for Microservices Architecture",
        "version": "1.0.17"
    },
    "last_serial": 4815745,
    "releases": {
        "1.0.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "a0c3079de527a853fb509ad61c284cd6",
                    "sha256": "caac1f35a6867e274988cc19ad5ae56fab6f79d2a55c3adc516cf964539a2911"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.1-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "a0c3079de527a853fb509ad61c284cd6",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 4530,
                "upload_time": "2018-04-25T13:09:15",
                "url": "https://files.pythonhosted.org/packages/75/58/797be8c4abdb1dde3978ecfb891ed59322e6b33480169f2c85221ad7a161/microservices_messaging_layer-1.0.1-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "decd4c8c7191701f5a847b90c7a78d4d",
                    "sha256": "800a157d3733994a9b02955def905235c22c7762af42374fd77ef1687be1430f"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.1.tar.gz",
                "has_sig": false,
                "md5_digest": "decd4c8c7191701f5a847b90c7a78d4d",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 2901,
                "upload_time": "2018-04-25T13:09:17",
                "url": "https://files.pythonhosted.org/packages/a6/c6/cf806152246792687c16c8a4be06281315564fd0727c6e6103e58b70614e/microservices_messaging_layer-1.0.1.tar.gz"
            }
        ],
        "1.0.15": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "e81bb5ff492b40bebcb465fd9c2ec526",
                    "sha256": "baafa2a9d3fe030d31c98e73acfff63217d52c434c8344d436a37f0b50f39d03"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.15-py2-none-any.whl",
                "has_sig": false,
                "md5_digest": "e81bb5ff492b40bebcb465fd9c2ec526",
                "packagetype": "bdist_wheel",
                "python_version": "py2",
                "requires_python": "~=3.6",
                "size": 11392,
                "upload_time": "2019-02-08T15:09:06",
                "url": "https://files.pythonhosted.org/packages/50/48/40cfd2b5d3b8fc1f87eab6d2afa6218907c2587bc0b53a694dd0f0a0644d/microservices_messaging_layer-1.0.15-py2-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "12ea8c3f283d6e849bbb232f9c7b8c63",
                    "sha256": "393480a1af84d0ca3021039ec42e2fb5c4ecd64a6d01ecdd5ed30fad7c56b40c"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.15.tar.gz",
                "has_sig": false,
                "md5_digest": "12ea8c3f283d6e849bbb232f9c7b8c63",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 6389,
                "upload_time": "2019-02-08T15:09:08",
                "url": "https://files.pythonhosted.org/packages/55/2c/f53a3c4db389e94b08542cbe95c941506baefc02e56169867313b810f3e8/microservices_messaging_layer-1.0.15.tar.gz"
            }
        ],
        "1.0.17": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "0a95c03cb4364feebe496c4ad8b9207c",
                    "sha256": "6a9ef7606a960a886193938e87841127da6f851a9c0d96a512d9b31fd795fda3"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.17-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "0a95c03cb4364feebe496c4ad8b9207c",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 11436,
                "upload_time": "2019-02-13T13:39:06",
                "url": "https://files.pythonhosted.org/packages/53/34/ccfe388d3ce305b8f25454649bc30dbd0e62029f619257b621663dc66dc6/microservices_messaging_layer-1.0.17-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "e63f803ceab7e3a15bcf91f748e134c1",
                    "sha256": "1dfe57f5008804b05f4981905e46258d83258908b8bc95530e6bed85f95e3d2a"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.17.tar.gz",
                "has_sig": false,
                "md5_digest": "e63f803ceab7e3a15bcf91f748e134c1",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 6429,
                "upload_time": "2019-02-13T13:39:07",
                "url": "https://files.pythonhosted.org/packages/2b/64/5fded284d82779643986bbc76eb16a1a19d370a2e7c14dc154f94e1f9b57/microservices_messaging_layer-1.0.17.tar.gz"
            }
        ],
        "1.0.3": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "da6e0a9767d00575c5f76cd17b74d505",
                    "sha256": "83b5e6621908fc44e92f78f0305b127a387aa184ce6d107723f1a0dec11197d9"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.3-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "da6e0a9767d00575c5f76cd17b74d505",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 6127,
                "upload_time": "2018-05-31T10:25:36",
                "url": "https://files.pythonhosted.org/packages/5f/03/45845ce7622fd00688695c06c999578c740087be30d41011acb15cedc210/microservices_messaging_layer-1.0.3-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "a7c87a599d3944bd6a9dd0cde7a08588",
                    "sha256": "11ca28bf94ea740d826ba6622c167f544863220fcbdc279931f7b678d92e9c3e"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.3.tar.gz",
                "has_sig": false,
                "md5_digest": "a7c87a599d3944bd6a9dd0cde7a08588",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 3519,
                "upload_time": "2018-05-31T10:25:38",
                "url": "https://files.pythonhosted.org/packages/a0/48/5f6382fc712d5a34632732589f0354923d4ef9565a4cc7635b33af0b7af4/microservices_messaging_layer-1.0.3.tar.gz"
            }
        ],
        "1.0.4": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "3f16d2c5fd92cc271909da7a622a2379",
                    "sha256": "1882d645cd53ec125caa99b7564c72365cfa2862c2e835c9b807f069060a5225"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.4-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "3f16d2c5fd92cc271909da7a622a2379",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 6154,
                "upload_time": "2018-06-13T17:08:01",
                "url": "https://files.pythonhosted.org/packages/9a/47/4af9354398eeb8afcc05778092577388b12ab83cd2f3801a00f979f78b07/microservices_messaging_layer-1.0.4-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "836012eadee612e2a4e16342f1cfd327",
                    "sha256": "e189c7755b171d114a3c420de20a559e84018e8fccb1784e2ab7b7330af93079"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.4.tar.gz",
                "has_sig": false,
                "md5_digest": "836012eadee612e2a4e16342f1cfd327",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 3531,
                "upload_time": "2018-06-13T17:08:02",
                "url": "https://files.pythonhosted.org/packages/15/6c/bf943a21a8680ad7e41e9f87134be6099556c7155e30090567b3d3e0f307/microservices_messaging_layer-1.0.4.tar.gz"
            }
        ],
        "1.0.5": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "0dd728b6a8a57db02ec3d43778c0c852",
                    "sha256": "46ee9d97633f547624b79f3cfb88d516e2d9d152a69b5df7fb6065bc95b507b4"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.5-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "0dd728b6a8a57db02ec3d43778c0c852",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 6777,
                "upload_time": "2018-06-15T11:17:27",
                "url": "https://files.pythonhosted.org/packages/59/62/309dbe69ca6949808a245cf44f5ac1b07f32670c14ff23e35c08105adcfd/microservices_messaging_layer-1.0.5-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "882dc94f4015a4e8e5ab1caa35650a94",
                    "sha256": "e53f942acfa3622b3e66b7311e4fb6fc215943fa71eeca44b5456370ebd4d7ee"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.5.tar.gz",
                "has_sig": false,
                "md5_digest": "882dc94f4015a4e8e5ab1caa35650a94",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 3664,
                "upload_time": "2018-06-15T11:17:28",
                "url": "https://files.pythonhosted.org/packages/cb/dd/0232cded4317e22fa0b482089a1b6ce864861bc453e3ba1a8b742ab62aaa/microservices_messaging_layer-1.0.5.tar.gz"
            }
        ],
        "1.0.6": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "a3f30e5d9f05e8dc6ec38514f3130f5d",
                    "sha256": "6d5e495a992855a8b9c1606e793a3eb3814906b684e12c5228b156d3bce6e1a9"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.6-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "a3f30e5d9f05e8dc6ec38514f3130f5d",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 6771,
                "upload_time": "2018-06-15T11:25:39",
                "url": "https://files.pythonhosted.org/packages/02/af/d5ae296a882814cfba792fdbc598c21357ca87095ea86904bd7f3a8ac9bb/microservices_messaging_layer-1.0.6-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "d71279428a67ef99524cd166b8ebd2ce",
                    "sha256": "e7d946d52f756a7c81219ce25d2539b99694ccc8f0659c83459dee7864a39189"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.6.tar.gz",
                "has_sig": false,
                "md5_digest": "d71279428a67ef99524cd166b8ebd2ce",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 3654,
                "upload_time": "2018-06-15T11:25:40",
                "url": "https://files.pythonhosted.org/packages/6e/27/0715d583d51ebddddd8b4690f2d03a74d8b5d26ced94a94aa1168373c49d/microservices_messaging_layer-1.0.6.tar.gz"
            }
        ],
        "1.0.7": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "ba7e10a9999660dcb43db5582721ecf9",
                    "sha256": "e83ad6ff1b65f3c6c56d4246bc35d3e628c977ae581dfb9675726533a57d562d"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.7-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "ba7e10a9999660dcb43db5582721ecf9",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 7852,
                "upload_time": "2018-06-25T14:35:16",
                "url": "https://files.pythonhosted.org/packages/c3/b5/2b18d086fc4c994a338c867b21ad2c8c5c7eacb3826613e77b0a2dec1f26/microservices_messaging_layer-1.0.7-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "f46e6f2855f377b6d8421123fdf2c574",
                    "sha256": "92d0656ec3ed0bc7999381e108d2914f30359c4b670cebacfee7c3facbd97806"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.7.tar.gz",
                "has_sig": false,
                "md5_digest": "f46e6f2855f377b6d8421123fdf2c574",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 3895,
                "upload_time": "2018-06-25T14:35:17",
                "url": "https://files.pythonhosted.org/packages/8b/10/809c820fb500456160e0d85b9c82104f96f6d19bb01eb38f39b2dd3e4096/microservices_messaging_layer-1.0.7.tar.gz"
            }
        ],
        "1.0.8": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "867c93381def754c38cdd47be41c7606",
                    "sha256": "586742902441789e4104637bc90c9cc031071e032f468631b270d09f914ded5f"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.8.macosx-10.9-x86_64.tar.gz",
                "has_sig": false,
                "md5_digest": "867c93381def754c38cdd47be41c7606",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": "~=3.6",
                "size": 11302,
                "upload_time": "2019-02-06T10:18:56",
                "url": "https://files.pythonhosted.org/packages/c3/dd/be3d6cd301f71c6db4c1ae35f827a13f7f44934b8837c61e6f80a296ab54/microservices_messaging_layer-1.0.8.macosx-10.9-x86_64.tar.gz"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "d5f41a1241ba56d8c21216a69ecadb48",
                    "sha256": "d0bf9c4c1b3ad6e7f5a7df9706c6fbf14120064a009fedcca69617b5da9bb9d7"
                },
                "downloads": -1,
                "filename": "microservices_messaging_layer-1.0.8-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "d5f41a1241ba56d8c21216a69ecadb48",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": "~=3.6",
                "size": 7912,
                "upload_time": "2018-06-25T19:07:58",
                "url": "https://files.pythonhosted.org/packages/08/f9/684a874e5e45a474a84966cbd1ffbf16cb7951661b5e98ac5db382bf6047/microservices_messaging_layer-1.0.8-py3-none-any.whl"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "0a95c03cb4364feebe496c4ad8b9207c",
                "sha256": "6a9ef7606a960a886193938e87841127da6f851a9c0d96a512d9b31fd795fda3"
            },
            "downloads": -1,
            "filename": "microservices_messaging_layer-1.0.17-py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "0a95c03cb4364feebe496c4ad8b9207c",
            "packagetype": "bdist_wheel",
            "python_version": "py3",
            "requires_python": "~=3.6",
            "size": 11436,
            "upload_time": "2019-02-13T13:39:06",
            "url": "https://files.pythonhosted.org/packages/53/34/ccfe388d3ce305b8f25454649bc30dbd0e62029f619257b621663dc66dc6/microservices_messaging_layer-1.0.17-py3-none-any.whl"
        },
        {
            "comment_text": "",
            "digests": {
                "md5": "e63f803ceab7e3a15bcf91f748e134c1",
                "sha256": "1dfe57f5008804b05f4981905e46258d83258908b8bc95530e6bed85f95e3d2a"
            },
            "downloads": -1,
            "filename": "microservices_messaging_layer-1.0.17.tar.gz",
            "has_sig": false,
            "md5_digest": "e63f803ceab7e3a15bcf91f748e134c1",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": "~=3.6",
            "size": 6429,
            "upload_time": "2019-02-13T13:39:07",
            "url": "https://files.pythonhosted.org/packages/2b/64/5fded284d82779643986bbc76eb16a1a19d370a2e7c14dc154f94e1f9b57/microservices_messaging_layer-1.0.17.tar.gz"
        }
    ]
}