fatz/covidify

Covidify 餐厅注册服务示例镜像

该镜像为一个餐厅注册服务的端到端示例应用，主要用于演示DC/OS和Kubernetes平台上多状态组件（Cassandra、Kafka）的集成、负载均衡配置及监控能力，目前处于早期开发阶段。

核心功能

1. 接收并存储餐厅访客数据到Cassandra和Kafka等多状态组件
2. 通过Locust和Boom工具模拟用户访问行为
3. 暴露Prometheus监控端点，支持平台监控集成
4. 支持DC/OS EdgeLB负载均衡和Kubernetes Ingress配置

使用场景

• 技术人员学习DC/OS平台上分布式应用的部署与管理
• 实践Kubernetes环境下Cassandra集群的集成与数据操作
• 掌握负载均衡（EdgeLB/Ingress）在分布式应用中的配置方法
• 学习Prometheus监控端点的暴露与集成

配置说明

DC/OS环境部署

1. 启动Cassandra集群

bash
# 运行3节点Cassandra集群（需DC/OS集群支持）

2. 获取Cassandra节点信息

bash
# 获取节点0任务ID
dcos task list testing.covidify.cassandra__node-0 --json | jq -r '.[0].id'
# 进入节点0 shell
dcos task exec --tty --interactive <task-id> "/bin/sh"
# 执行CQL操作
dcos cassandra --name "testing/covidify/cassandra" endpoints native-client | jq -r '.dns | map(split(":")[0])[0]'
apache-cassandra-*/bin/cqlsh <nodelist>
# 导入数据模型（model.csql）

3. 部署Marathon应用

json
{
  "env": {
    "COVIDIFY_CASSANDRA": "node-0-server.testingcovidifycassandra.autoip.dcos.thisdcos.directory,node-1-server.testingcovidifycassandra.autoip.dcos.thisdcos.directory,node-2-server.testingcovidifycassandra.autoip.dcos.thisdcos.directory"
  },
  "id": "/testing/covidify/api",
  "instances": 1,
  "portDefinitions": [],
  "container": {
    "type": "MESOS",
    "volumes": [],
    "docker": {
      "image": "fatz/covidify",
      "forcePullImage": false,
      "parameters": []
    }
  },
  "cpus": 0.1,
  "mem": 256,
  "requirePorts": false,
  "networks": [],
  "healthChecks": [],
  "fetch": [],
  "constraints": []
}

4. 配置EdgeLB池

创建pool.json文件并执行部署：

bash
dcos edgelb create pool.json

pool.json内容：

json
{
  "apiVersion": "V2",
  "name": "http",
  "count": 1,
  "haproxy": {
    "frontends": [{
      "bindPort": 80,
      "protocol": "HTTP",
      "linkBackend": {
        "map": [{
          "hostEq": "covidify.dcos.d2iq.com",
          "backend": "covidifyapi"
        }]
      }
    }],
    "backends": [{
      "name": "covidifyapi",
      "protocol": "HTTP",
      "services": [{
        "marathon": {
          "serviceID": "/testing/covidify/api"
        },
        "endpoint": {
          "portName": "http"
        }
      }]
    }]
  }
}

5. 测试API

bash
curl -H "Host: covidify.dcos.d2iq.com" -X POST "http://<yourclusteraddress>/visit" -H  "accept: */*" -H  "Content-Type: application/json" -d "{\"id\":\"d290f1ee-6c54-4b01-90e6-d701748f0851\",\"table_number\":\"outside-1\",\"visitors\":[{\"name\":\"John Doe\",\"email\":\"john.doe@googlemail.com\",\"phone\":\"+49-30-123456789\",\"country\":\"DEU\",\"city\":\"Berlin\",\"zip_code\":\"11011\",\"street\":\"Platz der Republik 1\"}],\"risk\":{\"risk\":\"low\",\"description\":\"string\"}}"

Kubernetes环境部署

1. 启动Cassandra集群（使用Cass Operator）

bash
K8S_VER=1.18 kubectl apply -f https://raw.githubusercontent.com/datastax/cass-operator/v1.4.1/docs/user/cass-operator-manifests-$K8S_VER.yaml
kubectl -n cass-operator apply -f deployments/dkp/cassandra.yml

2. 导入数据模型

bash
# 获取Cassandra超级用户凭证
CASS_PASS=$(kubectl -n cass-operator get secret cluster1-superuser -o json | jq -r '.data.password' | base64 --decode)
CASS_USER=$(kubectl -n cass-operator get secret cluster1-superuser -o json | jq -r '.data.username' | base64 --decode)
# 执行CQL导入
kubectl -n cass-operator exec -ti cluster1-dc1-default-sts-0 -c cassandra -- sh -c "cqlsh -u '$CASS_USER' -p '$CASS_PASS'"
# 粘贴model.csql内容

3. 部署应用

bash
# 创建命名空间
kubectl create namespace covidify
# 创建Cassandra凭证密钥
kubectl create secret generic cassandra-credentials -n covidify --from-literal=COVIDIFY_USERNAME=$(kubectl -n cass-operator get secret cluster1-superuser -o json | jq -r '.data.username' | base64 --decode) --from-literal=COVIDIFY_PASSWORD=$(kubectl -n cass-operator get secret cluster1-superuser -o json | jq -r '.data.password' | base64 --decode)
# 部署应用、服务及Ingress
kubectl apply -n covidify -f deployments/dkp/api.yml