小编Xpy*_*pyM的帖子

所以我的目标是让几个容器使用rabbitmq 消息相互交互（rabbitmq 服务器在一个单独的容器中）

兔子.py

class Rabbit:
    host = 'rabbitmq-host'
    userid = 'test'
    password = 'test'


class Consumer(Rabbit):

    def __init__(self, exchange_name):
        self.exchange_name = exchange_name
        self.connection = None
        try:
            credentials = pika.PlainCredentials(self.userid, self.password)
            params = pika.ConnectionParameters(self.host, 5672, '/', credentials)
            self.connection = pika.BlockingConnection(params)
        except Exception as ex:
            print(ex)
            if self.connection is not None and self.connection.is_open:
                self.connection.close()
            raise ex

        self.channel = self.connection.channel()

凭证测试：测试存在，我重新检查。

然后从另一个文件（main.py）创建消费者

c = Consumer('media')

docker-compose.yml

version: '3'
services:

rabbitmq-server:
  image: "rabbitmq:3-management"
  hostname: "rabbitmq-host"
  environment:
    RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
    RABBITMQ_DEFAULT_USER: "test"
    RABBITMQ_DEFAULT_PASS: "test"
    RABBITMQ_DEFAULT_VHOST: …

所以我使用DataContext作为与DB的连接.我想从DB中获取所有公司,但删除的公司除外.我的公司对象:

[Table(Name = "Companies")]
class Company {
    [Column(IsPrimaryKey = true, IsDbGenerated = true)]
    public int Id { get; set; }
    [Column]
    public bool Deleted { get; set; }
    [Column]
    public DateTime DateCreated { get; set; }
    [Column]
    public DateTime? DateModified { get; set; }
    [Column]
    public string Name { get; set; }

    private EntitySet<Platform> _Platforms;
    [Association(Storage = "_Platforms", OtherKey = "CompanyId")]
    public virtual EntitySet<Platform> Platforms {
        get {
            return this._Platforms;
        }
        set {
            this._Platforms.Assign(value);
        }
    }

    public Company() {
        this._Platforms …