Async Eureka client
Asynchronous Naive Eureka client for the Netflix OSS/Spring Cloud bundled eureka stack.
$ pip install wasp-eureka
The surface area of this module is pretty small, effectively you just need to care about the wasp_gateway.EurekaClient class and its methods:
import asyncio from wasp_gateway import EurekaClient # no spaces or underscores, this needs to be url-friendly app_name = 'test-app' port = 8080 # This needs to be an IP accessible by anyone that # may want to discover, connect and/or use your service. ip = '127.0.0.1' my_eureka_url = 'https://service-discovery.mycompany.com/eureka' loop = asyncio.get_event_loop() eureka = EurekaClient(app_name, port, ip, eureka_url=my_eureka_url, loop=loop) async def main(): # Presuming you want your service to be available via eureka result = await eureka.register() assert result, 'Unable to register' # You need to provide a heartbeat to renew the lease, # otherwise the eureka server will expel the service. # The default is 90s, so any time <90s is ok while True: await asyncio.sleep(67) await eureka.renew() loop.run_until_complete(main(loop=loop))
Depending on your framework, you probably want to use a scheduler (see APScheduler for support for a wide number of python frameworks)
Creating a Release
Bumpversion provides a simplified way to manage versioning, to check the dry run before running it:
$ bumpversion [patch,minor,major] --dry-run --verbose
$ bumpversion patch
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
wasp-eureka-0.0.3.tar.gz (4.9 kB view hashes)
wasp_eureka-0.0.3-py3.6.egg (8.0 kB view hashes)
Hashes for wasp_eureka-0.0.3-py3-none-any.whl