结构控制框架
fabric-cf的Python项目详细描述
控制框架
此存储库包含结构控制框架和参与者实现。在
概述
结构控制框架有3个参与者
- 控制器
- 经纪人
- 总经理
经纪人
Broker是CF的代理，它从多个聚合管理器收集资源可用性信息，并可以代表他们做出资源承诺。更多详情请参见here
总经理
AM是负责管理聚合资源的CF代理。由骨料所有者控制。向代理和控制器/协调器提供资源承诺。更多详情请参见here
配器
Orchestrator是CF的一个代理，它将用户请求的分配决策（嵌入）到可用资源中。与用户通信以收集切片请求，与代理或聚合管理器通信以收集资源承诺，与聚合管理器通信以提供承诺的资源。创建切片，配置资源，维护其状态，修改切片和切片。更多详情请参见here
要求
Python 3.7+
配置
网络AM、VM AM和Broker的配置文件示例可在config目录下找到：
$ ls -ltr config
total 40
-rw-r--r-- 1 komalthareja staff 4312 Jul 14 14:38 config.net-am.yaml
-rw-r--r-- 1 komalthareja staff 7277 Jul 14 14:38 config.vm-am.yaml
-rw-r--r-- 1 komalthareja staff 3746 Jul 14 14:38 config.broker.yaml
-rw-r--r-- 1 komalthareja staff 3746 Jul 14 14:38 config.orchestrator.yaml
构建Docker映像
权威Docker图像
^{pr2}$Broker Docker图像
docker build -f Dockerfile-broker -t broker .
Orchestrator Docker图像
docker build -f Dockerfile-orchestrator -t orchestrator .
开发部署
Kafa需要本地部署。下面的步骤详细说明了如何启动Kafka集群的开发
卡夫卡星团
生成凭证
您必须生成CA证书（如果已经有CA证书，则使用您的证书），然后为代理和客户机生成密钥库和信任库。在
cd $(pwd)/secrets
./create-certs.sh
cd -
为docker compose设置环境变量。将env.template复制为.env。下面是.env中的配置示例
# docker-compose environment file
#
# When you set the same environment variable in multiple files,
# here’s the priority used by Compose to choose which value to use:
#
# 1. Compose file
# 2. Shell environment variables
# 3. Environment file
# 4. Dockerfile
# 5. Variable is not defined
# Kafka configuration
KAFKA_SSL_SECRETS_DIR=./secrets
提起容器
你可以使用docker compose-卡夫卡·亚姆文件来启动一个包含
- 经纪人
- 动物园管理员
- 架构注册表
使用下面的命令启动集群
docker-compose -f docker-compose-kafka.yaml up -d
这将产生以下容器：
NAMES
df0e3be0b641 confluentinc/cp-schema-registry:latest "/etc/confluent/dock…" 7 minutes ago Up 7 minutes 0.0.0.0:8081->8081/tcp schemaregistry
82a0a59c117b confluentinc/cp-kafka:latest "/etc/confluent/dock…" 7 minutes ago Up 7 minutes 0.0.0.0:9092->9092/tcp, 0.0.0.0:19092->19092/tcp broker1
1fea39fedf6a fabrictestbed/postgres:12.3 "docker-entrypoint.s…" 7 minutes ago Up 7 minutes 0.0.0.0:8432->5432/tcp actordb
c6b824b7d3c6 confluentinc/cp-zookeeper:latest "/etc/confluent/dock…" 7 minutes ago Up 7 minutes 2888/tcp, 0.0.0.0:2181->2181/tcp, 3888/tcp zookeeper
- 项目
标签：
欢迎加入QQ群-->： 979659372
