Stack Overflow
Stack Overflow

Questions tagged [nameko]

Python framework for building microservices

Python framework for building microservices

55 questions
19
votes
1 answer

Connecting to rabbitmq docker container from service in another container

I've done a lot of searching but I cannot fix this issue. I have a basic Rabbitmq container running via this command: docker run -d --hostname rabbitmqhost --name rabbitmq -p 15672:15672 -p 5672:5672 rabbitmq:3-management I am using nameko to…
steve
  • 537
  • 1
  • 7
  • 17
17
votes
4 answers

How can i combine flask and nameko?

How can i combine Flask web application and Nameko microservices? Let me give you some context. I have flask-based (http://flask.pocoo.org) web application. This application can execute long (5-10 minutes) tasks. I want to be able to write and…
Zhorzh Alexandr
  • 1,469
  • 2
  • 17
  • 28
8
votes
2 answers

wrap_socket() got an unexpected keyword argument '_context' and deserialize(error)

I try to use requests to get a url of file. It works well locally but it doesn't work with nameko. I tried 3 libs of python3.7. But all has the same error. import urllib.request,urllib3,requests it works well locally like this: import requests url =…
yuut007
  • 81
  • 1
  • 4
4
votes
0 answers

Potential Nameko concurrency issues with pyscopg2 driver for Postgresql

We are building a Python microservices application with Posgresql as service datastore. At first glance Nameko seems a good starting point. However the Nameko documentation section on Concurrency includes this statement: Nameko is built on top of…
Ricibob
  • 7,505
  • 5
  • 46
  • 65
4
votes
1 answer

How to use asyncio module call nameko service concurrently

I write a asyncio program like this. A forever run loop start 4 event as the same time. Every event will run the rpc service. In the nameko service, I implement the service with time.sleep(10). I confused why the service is finished every 10…
user10970428
  • 41
  • 3
3
votes
2 answers

Nameko/RabbitMQ: OSError: Server unexpectedly closed connection

I have two nameko services that communicate using RPC via RabbitMQ. Locally with docker-compose all works fine. Then I deployed everything to Kubernetes/Istio cluster on DigitalOcean and started get the following errors. It repeats continuously 1…
Max
  • 404
  • 2
  • 17
  • 39
2
votes
1 answer

Unable to get nameko-injector Python package to work

I am busy programming a microservice backend in Python using Nameko. While searching for a good dependency injection package I came a across Injector. I really liked it and wanted to use it together with Nameko. Then I noticed a small problem:…
Job Deleij
  • 21
  • 2
2
votes
2 answers

How to make RPC calls asynchronous in nameko?

I am using nameko to build an ETL pipeline with a micro-service architecture, and I do not want to wait for a reply after making a RPC request. from nameko.rpc import rpc, RpcProxy class Scheduler(object): name = "scheduler" task_runner =…
Satnam Sandhu
  • 610
  • 1
  • 10
  • 25
2
votes
2 answers

how to stop initial class when use nameko run a service

Hi here is an example of my project, I would like to use nameko run Test:A, And I find that the class A will be inital repeatedly during run this service. Actuallly，I want to connect to a service and do something repeat and I don't want to initial…
helijia21
  • 23
  • 4
2
votes
1 answer

Cassandra doesn't complete connection with EventletConnection

In an otherwise stable environment, when I call cluster.connect(), the code just hangs indefinitely, no errors or timeout messages. The connection is contained inside a Nameko service. I suspect it is related to the Nameko service code, particularly…
The other other Alan
  • 1,868
  • 12
  • 21
2
votes
1 answer

Where does the data of postgresql container save ans, and also where the location of container is?

I'm using the nameko from GitHub https://github.com/nameko/nameko-examples and I deploy this application on docker. Once I stop the container all the data lost and I also not able to find the location of the container. I want to store each database…
rupesh
  • 471
  • 5
  • 5
2
votes
0 answers

How to deploy docker micro services individually using Gitlab CI and allow them to talk?

I'm working on trying to create a micro service system able to be deployed using docker, and I've run into a few conceptual road blocks that I'd love some help with. So each of my micro services are running on Python's Nameko framework with RabbitMQ…
AlexW.H.B.
  • 1,781
  • 3
  • 25
  • 50
2
votes
0 answers

Python: strange enum subclass behaviour with json serialization

I'm experiencing a strange behaviour while trying to serialize some data to send as argument to a remote procedure using Nameko and rabbitmq to a microservice: A semplification of the problem structured into 3 files under a dir named…
CodeP
  • 274
  • 2
  • 7
2
votes
1 answer

eventlet.monkey_patch() breaks ipdb in docker container

So I am using the micro-servicing python package nameko which runs a service using eventlet and calls eventlet.monkey_patch() on import. I have deciphered that it is this piece of code that is blocking any debug attempts via ipdb. The ipdb console…
steve
  • 537
  • 1
  • 7
  • 17
1
vote
1 answer

How can I get the dispatch service name?

Using nameko, I have a green_event that can be dispatched by two different services: @event_handler("service1", "green_event") @event_handler("service2", "green_event") def green_event(self, payload): # ... # ... How can I get the variable…
Grigory Ilizirov
  • 1,030
  • 1
  • 8
  • 26
1
2 3 4