| Name | adapter-client JSON |
| Version |
2.1.2
JSON |
| download |
| home_page | None |
| Summary | Клиент для взаимодействия со СМЭВ3 посредством Адаптера |
| upload_time | 2024-06-24 06:20:16 |
| maintainer | None |
| docs_url | None |
| author | BARS Group |
| requires_python | None |
| license | MIT |
| keywords |
|
| VCS |
|
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
# Клиент для взаимодействия со СМЭВ3 посредством Адаптера
## Подключение
settings:
INSTALLED_APPS = [
'adapter_client'
]
services:
from adapter_client.adapters.smev.adapter import adapter
from adapter_client.adapters.smev.services.base import AbstractService
from adapter_client.core.domain.model import Message
class ROGDINFService(AbstractService):
"""
Сервис обрабатывающий сообщения со сведениями о рождении.
"""
message_type = 'urn://x-artefacts-zags-rogdinf/root/112-51/4.0.1'
def process_message(self, message: Message):
# сообщение на которое получен ответ
reply_to = message.reply.to
...
class ApplicationRequestService(AbstractService):
"""
Сервис обрабатывающий запросы на зачисление (в качестве поставщика).
"""
message_type = (
'http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1'
)
def process_message(self, message: Message):
# обрабатываем сообщение-запрос
...
# отправляем ответ на запрос
adapter.send(
Message(
# необходимо указать что сообщение является ответом
reply_to=message,
# остальные поля сообщения
...
)
)
apps:
from django.apps.config import AppConfig as AppConfigBase
class AppConfig(AppConfigBase):
name = __package__
def ready(self):
self._init_adapter_client()
self._register_services()
def _init_adapter_client(self):
from adapter_client.config import ProductConfig, set_config
from tasks import BaseTask
set_config(ProductConfig(async_task_base=BaseTask))
def _register_services(self):
from adapter_client.adapters.smev.adapter import adapter
from .services import ApplicationRequestService, ROGDINFService
adapter.register_service(ApplicationRequestService(), ROGDINFService())
## Запуск тестов
$ tox
## API
### Передача сообщения
from adapter_client.adapters.smev.adapter import adapter
from adapter_client.core.domain.model import Message
message = Message(
message_type='Foo',
body='<foo>bar</foo>',
attachments=['http://domain.com/attach1', 'http://domain.com/attach2'],
test=True
)
adapter.send(message)
Дальнейшая обработка сообщений производится Celery в фоновом режиме.
### Получение ответа на сообщение
Ответы на отправленные сообщения собираются периодической задачей
и передаются зарегистрированным сервисам.
Raw data
{
"_id": null,
"home_page": null,
"name": "adapter-client",
"maintainer": null,
"docs_url": null,
"requires_python": null,
"maintainer_email": null,
"keywords": null,
"author": "BARS Group",
"author_email": "education_dev@bars-open.ru",
"download_url": "https://files.pythonhosted.org/packages/56/ca/7af2b72d92017f74907b82a7c6f367c6db1ed40cbbcdd2cdec5f663fe9ba/adapter_client-2.1.2.tar.gz",
"platform": null,
"description": "# \u041a\u043b\u0438\u0435\u043d\u0442 \u0434\u043b\u044f \u0432\u0437\u0430\u0438\u043c\u043e\u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f \u0441\u043e \u0421\u041c\u042d\u04123 \u043f\u043e\u0441\u0440\u0435\u0434\u0441\u0442\u0432\u043e\u043c \u0410\u0434\u0430\u043f\u0442\u0435\u0440\u0430\n## \u041f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435\nsettings:\n\n INSTALLED_APPS = [\n 'adapter_client'\n ]\n\nservices:\n \n from adapter_client.adapters.smev.adapter import adapter\n from adapter_client.adapters.smev.services.base import AbstractService\n from adapter_client.core.domain.model import Message\n\n\n class ROGDINFService(AbstractService):\n \"\"\"\n \u0421\u0435\u0440\u0432\u0438\u0441 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u044e\u0449\u0438\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0441\u043e \u0441\u0432\u0435\u0434\u0435\u043d\u0438\u044f\u043c\u0438 \u043e \u0440\u043e\u0436\u0434\u0435\u043d\u0438\u0438.\n \"\"\"\n message_type = 'urn://x-artefacts-zags-rogdinf/root/112-51/4.0.1'\n \n def process_message(self, message: Message):\n\t\t\t# \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0430 \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043f\u043e\u043b\u0443\u0447\u0435\u043d \u043e\u0442\u0432\u0435\u0442\n\t\t\treply_to = message.reply.to\n ...\n \n class ApplicationRequestService(AbstractService):\n \"\"\"\n \u0421\u0435\u0440\u0432\u0438\u0441 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u044e\u0449\u0438\u0439 \u0437\u0430\u043f\u0440\u043e\u0441\u044b \u043d\u0430 \u0437\u0430\u0447\u0438\u0441\u043b\u0435\u043d\u0438\u0435 (\u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u043f\u043e\u0441\u0442\u0430\u0432\u0449\u0438\u043a\u0430).\n \"\"\"\n message_type = (\n 'http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1'\n )\n def process_message(self, message: Message):\n # \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435-\u0437\u0430\u043f\u0440\u043e\u0441\n ...\n\n # \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u043e\u0442\u0432\u0435\u0442 \u043d\u0430 \u0437\u0430\u043f\u0440\u043e\u0441\n adapter.send(\n Message(\n # \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u044c \u0447\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043e\u0442\u0432\u0435\u0442\u043e\u043c\n reply_to=message,\n # \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435 \u043f\u043e\u043b\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\n ...\n )\n )\n\n\napps:\n\n from django.apps.config import AppConfig as AppConfigBase\n\n class AppConfig(AppConfigBase):\n\n name = __package__\n\n def ready(self):\n self._init_adapter_client()\n self._register_services()\n\n def _init_adapter_client(self):\n from adapter_client.config import ProductConfig, set_config\n from tasks import BaseTask\n\n set_config(ProductConfig(async_task_base=BaseTask))\n \n def _register_services(self):\n from adapter_client.adapters.smev.adapter import adapter\n from .services import ApplicationRequestService, ROGDINFService\n \n adapter.register_service(ApplicationRequestService(), ROGDINFService())\n\n\n## \u0417\u0430\u043f\u0443\u0441\u043a \u0442\u0435\u0441\u0442\u043e\u0432\n $ tox\n\n## API\n\n### \u041f\u0435\u0440\u0435\u0434\u0430\u0447\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\n\n from adapter_client.adapters.smev.adapter import adapter\n from adapter_client.core.domain.model import Message\n\n message = Message(\n message_type='Foo',\n body='<foo>bar</foo>',\n attachments=['http://domain.com/attach1', 'http://domain.com/attach2'],\n test=True\n )\n\n adapter.send(message)\n\n\u0414\u0430\u043b\u044c\u043d\u0435\u0439\u0448\u0430\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0441\u044f Celery \u0432 \u0444\u043e\u043d\u043e\u0432\u043e\u043c \u0440\u0435\u0436\u0438\u043c\u0435.\n\n### \u041f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u043e\u0442\u0432\u0435\u0442\u0430 \u043d\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435\n\n\u041e\u0442\u0432\u0435\u0442\u044b \u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u043d\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0441\u043e\u0431\u0438\u0440\u0430\u044e\u0442\u0441\u044f \u043f\u0435\u0440\u0438\u043e\u0434\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0435\u0439 \n\u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u044e\u0442\u0441\u044f \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c.\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "\u041a\u043b\u0438\u0435\u043d\u0442 \u0434\u043b\u044f \u0432\u0437\u0430\u0438\u043c\u043e\u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f \u0441\u043e \u0421\u041c\u042d\u04123 \u043f\u043e\u0441\u0440\u0435\u0434\u0441\u0442\u0432\u043e\u043c \u0410\u0434\u0430\u043f\u0442\u0435\u0440\u0430",
"version": "2.1.2",
"project_urls": null,
"split_keywords": [],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "b06f608de09517edca43b695a6110f927475a7fc27cd67e1c611b31965ea18d7",
"md5": "67857e205bae85e9ccdf461ec3f6cc4e",
"sha256": "3605c204a6c243ad70998255eb3092ad176dc9304ae92b9034e0963d1679b20d"
},
"downloads": -1,
"filename": "adapter_client-2.1.2-py3-none-any.whl",
"has_sig": false,
"md5_digest": "67857e205bae85e9ccdf461ec3f6cc4e",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": null,
"size": 41478,
"upload_time": "2024-06-24T06:20:14",
"upload_time_iso_8601": "2024-06-24T06:20:14.272062Z",
"url": "https://files.pythonhosted.org/packages/b0/6f/608de09517edca43b695a6110f927475a7fc27cd67e1c611b31965ea18d7/adapter_client-2.1.2-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "56ca7af2b72d92017f74907b82a7c6f367c6db1ed40cbbcdd2cdec5f663fe9ba",
"md5": "8c848594fda26537e7c16d1e0d05a1bf",
"sha256": "f24c31168a60be325da30826fb524275182931b1d217de24341d5b5eb461ff2b"
},
"downloads": -1,
"filename": "adapter_client-2.1.2.tar.gz",
"has_sig": false,
"md5_digest": "8c848594fda26537e7c16d1e0d05a1bf",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 32173,
"upload_time": "2024-06-24T06:20:16",
"upload_time_iso_8601": "2024-06-24T06:20:16.229955Z",
"url": "https://files.pythonhosted.org/packages/56/ca/7af2b72d92017f74907b82a7c6f367c6db1ed40cbbcdd2cdec5f663fe9ba/adapter_client-2.1.2.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-06-24 06:20:16",
"github": false,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"lcname": "adapter-client"
}
