cql-proxy

cql-proxy

实现传统驱动与现代数据库的无缝连接

cql-proxy是一款设计用于转发CQL流量到适当数据库服务的代理工具。它使不兼容的CQL驱动程序能够与DataStax Astra协同工作,涵盖旧版DataStax驱动程序和社区维护的CQL驱动程序。该工具还允许现有的Apache Cassandra或DataStax Enterprise应用无需修改代码即可迁移至Astra。cql-proxy提供多种配置选项,如命令行标志、环境变量和配置文件,确保部署灵活性。

cql-proxy数据库代理CQL流量Astra负载均衡Github开源项目

cql-proxy

GitHub Action Go Report Card

目录

什么是cql-proxy?

cql-proxy

cql-proxy旨在将应用程序的CQL流量转发到适当的数据库服务。它监听本地地址并安全地转发流量。

何时使用cql-proxy

cql-proxy边车使不受支持的CQL驱动程序能够与DataStax Astra一起工作。这些驱动程序包括DataStax的旧版[驱动程序]和社区维护的CQL驱动程序,如gocql驱动程序和rust-driver

cql-proxy还使当前使用Apache CassandraDataStax Enterprise (DSE)的应用程序能够使用Astra而无需任何代码更改。只需将应用程序配置为使用代理即可。

如果您正在使用DataStax [驱动程序]构建新应用程序,则不需要cql-proxy,因为驱动程序可以直接与Astra通信。DataStax驱动程序对Astra有出色的开箱即用支持,并在driver-guide指南中有详细的文档。

配置

使用-h--help标志显示所有标志及其相应的描述和环境变量(下面显示为以$开头的项)列表:

$ ./cql-proxy -h 用法: cql-proxy 标志: -h, --help 显示上下文相关的帮助。 -b, --astra-bundle=STRING Astra数据库的安全连接包路径。需要'--username'和'--password'。如果使用令牌或联系点选项则忽略($ASTRA_BUNDLE)。 -t, --astra-token=STRING 用于向Astra数据库进行身份验证的令牌。需要'--astra-database-id'。如果使用包路径或联系点选项则忽略($ASTRA_TOKEN)。 -i, --astra-database-id=STRING Astra数据库的数据库ID。需要'--astra-token'($ASTRA_DATABASE_ID) --astra-api-url="https://api.astra.datastax.com" Astra API的URL($ASTRA_API_URL) --astra-timeout=10s 检索包和元数据时联系Astra的超时时间($ASTRA_TIMEOUT) -c, --contact-points=CONTACT-POINTS,... 集群的联系点。如果使用包路径或令牌选项则忽略($CONTACT_POINTS)。 -u, --username=STRING 用于身份验证的用户名($USERNAME) -p, --password=STRING 用于身份验证的密码($PASSWORD) -r, --port=9042 连接到集群时使用的默认端口($PORT) -n, --protocol-version="v4" 连接到后端集群时使用的初始协议版本(默认: v4, 选项: v3, v4, v5, DSEv1, DSEv2) ($PROTOCOL_VERSION) -m, --max-protocol-version="v4" 后端集群支持的最大协议版本(默认: v4, 选项: v3, v4, v5, DSEv1, DSEv2) ($MAX_PROTOCOL_VERSION) -a, --bind=":9042" 用于绑定服务器的地址($BIND) -f, --config=CONFIG YAML配置文件($CONFIG_FILE) --debug 显示调试日志($DEBUG) --health-check 启用活性和就绪性检查($HEALTH_CHECK) --http-bind=":8000" 用于绑定HTTP服务器的地址,用于健康检查($HTTP_BIND) --heartbeat-interval=30s 对集群执行心跳的间隔($HEARTBEAT_INTERVAL) --idle-timeout=60s 成功心跳之间的持续时间,超过此时间后与集群的连接被视为无响应并关闭($IDLE_TIMEOUT) --readiness-timeout=30s 代理无法连接到后端集群的持续时间,超过此时间后被视为未就绪($READINESS_TIMEOUT) --idempotent-graph 如果为true,将默认将所有图查询视为幂等并自动重试。重试某些图查询可能很危险 -- 请谨慎使用($IDEMPOTENT_GRAPH)。 --num-conns=1 创建到后端集群的每个节点的连接数($NUM_CONNS) --proxy-cert-file=STRING PEM编码证书文件的路径,包含其中间证书链。用于加密代理客户端的流量($PROXY_CERT_FILE) --proxy-key-file=STRING PEM编码私钥文件的路径。用于加密代理客户端的流量($PROXY_KEY_FILE) --rpc-address=STRING 在'system.local'表中为'rpc_address'广告的地址。如果配置对等代理,则必须设置($RPC_ADDRESS) --data-center=STRING 系统表中使用的数据中心($DATA_CENTER) --tokens=TOKENS,... 系统表中使用的令牌。不推荐使用($TOKENS)

要向cql-proxy传递配置,可以使用命令行标志、环境变量或配置文件。以docker方法为例,以下示例展示了如何使用每种方法定义令牌和数据库ID。

使用标志

docker run -p 9042:9042 \ --rm datastax/cql-proxy:v0.1.5 \ --astra-token <astra-token> --astra-database-id <astra-datbase-id>

使用环境变量

docker run -p 9042:9042 \ --rm datastax/cql-proxy:v0.1.5 \ -e ASTRA_TOKEN=<astra-token> -e ASTRA_DATABASE_ID=<astra-datbase-id>

使用配置文件

代理设置也可以使用--config /path/to/proxy.yaml标志通过配置文件传递。这可以与命令行标志和环境变量混合使用。以下是一些示例配置文件:

contact-points: - 127.0.0.1 username: cassandra password: cassandra port: 9042 bind: 127.0.0.1:9042 # ...

或使用Astra令牌:

astra-token: <astra-token> astra-database-id: <astra-database-id> bind: 127.0.0.1:9042 # ...

所有配置键都与其命令行标志对应,例如--astra-bundle对应astra-bundle:--contact-points对应contact-points:等。

设置对等代理

具有数据中心感知负载均衡策略的多区域故障转移是多代理设置最有用的情况。

配置peers:时,每个代理必须设置--rpc-address(或yaml中的rpc-address:),并且必须与其对应的peers:条目匹配。此外,peers:只能在配置文件中设置,不能使用命令行标志设置。

多区域设置

以下是配置具有两个代理的多区域故障转移的示例。每个区域的集群都启动一个代理,使用该区域的包连接到集群。它们都共享一个包含完整代理列表的通用配置文件。

*注意:*多区域设置仅支持包。

cql-proxy --astra-bundle astra-region1-bundle.zip --username token --password <astra-token> \ --bind 127.0.0.1:9042 --rpc-address 127.0.0.1 --data-center dc-1 --config proxy.yaml
cql-proxy ---astra-bundle astra-region2-bundle.zip --username token --password <astra-token> \ --bind 127.0.0.2:9042 --rpc-address 127.0.0.2 --data-center dc-2 --config proxy.yaml

对等设置使用yaml文件配置。明确提供--data-center标志是个好主意,否则;这些值将从后端集群中提取,需要从system.localsystem.peers表中提取以正确设置对等的data-center:值。以下是proxy.yaml的示例:

peers: - rpc-address: 127.0.0.1 data-center: dc-1 - rpc-address: 127.0.0.2 data-center: dc-2

注意:peers:包含当前代理自身的条目是可以的,因为它们会被忽略。

入门

使用cql-proxy有三种方法:

  • 本地构建和运行cql-proxy
  • 运行安装了cql-proxy的docker镜像
  • 使用Kubernetes容器运行cql-proxy

本地构建和运行

  1. 构建cql-proxy

    go build
  2. 使用您想要的数据库运行。

    • DataStax Astra集群:

      ./cql-proxy --astra-token <astra-token> --astra-database-id <astra-database-id>

      可以使用这些[说明]生成<astra-token>。代理还支持使用Astra安全连接包以及使用这些[说明]生成的客户端ID和密钥:

      ./cql-proxy --astra-bundle <your-secure-connect-zip> \
      --username <astra-client-id> --password <astra-client-secret>
      
    • Apache Cassandra集群:

      ./cql-proxy --contact-points <集群节点IP或DNS名称> [--username <用户名>] [--password <密码>]

运行cql-proxy docker镜像

  1. 使用您想要的数据库运行。

docker run -p 9042:9042 \ datastax/cql-proxy:v0.1.5 \ --astra-token <astra-token> --astra-database-id <astra-database-id>

可以使用这些[说明]生成 <astra-token>。代理还支持使用 Astra 安全连接包,但需要将包挂载到容器中的卷:

docker run -v <your-secure-connect-bundle.zip>:/tmp/scb.zip -p 9042:9042 \ --rm datastax/cql-proxy:v0.1.5 \ --astra-bundle /tmp/scb.zip --username <astra-client-id> --password <astra-client-secret>
docker run -p 9042:9042 \ datastax/cql-proxy:v0.1.5 \ --contact-points <集群节点IP或DNS名称> [--username <用户名>] [--password <密码>]

如果您希望在使用完毕后删除 Docker 镜像,请在镜像名称 datastax/cql-proxy:v0.1.5 之前添加 --rm

使用 Kubernetes

在 Kubernetes 中使用 cql-proxy 需要以下几个步骤:

  1. 按照 Astra 说明生成令牌。此步骤将显示您的客户端 ID、客户端密钥和令牌;确保下载这些信息以备下一步使用。将安全包存储在 /tmp/scb.zip 中以匹配下面的示例。

  2. 创建 cql-proxy.yaml。您需要添加三组信息:参数、卷挂载和卷。完整示例可以在这里找到。

  • 参数:修改本地包位置、用户名和密码,使用上一步获得的客户端 ID 和客户端密钥作为容器参数。

    command: ["./cql-proxy"]
    args: ["--astra-bundle=/tmp/scb.zip","--username=Client ID","--password=Client Secret"]
    
  • 卷挂载:根据需要修改 /tmp/ 作为卷挂载。

    volumeMounts:
      - name: my-cm-vol
      mountPath: /tmp/
    
  • 卷:根据需要修改 configMap 文件名。在此示例中,它被命名为 cql-proxy-configmap。对 volumes 使用与 volumeMounts 相同的名称。

    volumes:
      - name: my-cm-vol
        configMap:
          name: cql-proxy-configmap        
    
  1. 创建配置映射。使用在 cql-proxy.yaml 中指定的相同安全包。

    kubectl create configmap cql-proxy-configmap --from-file /tmp/scb.zip
  2. 检查创建的配置映射。

    kubectl describe configmap cql-proxy-configmap Name: cql-proxy-configmap Namespace: default Labels: <none> Annotations: <none> Data ==== BinaryData ==== scb.zip: 12311 bytes
  3. 使用您创建的 YAML 文件创建 Kubernetes 部署:

    kubectl create -f cql-proxy.yaml
  4. 检查日志:

    kubectl logs <部署名称>

已知问题

令牌感知负载均衡

使用令牌感知负载均衡的驱动程序在使用 cql-proxy 时可能会打印警告或无法工作。因为 cql-proxy 将后端集群抽象为单个端点,这与期望集群中至少有"复制因子"数量节点的令牌感知驱动程序不太兼容。许多驱动程序会打印一个警告(可以忽略)并回退到类似轮询的方式,但其他驱动程序可能会因错误而失败。对于因错误而失败的驱动程序,需要禁用令牌感知或配置轮询负载均衡策略。

编辑推荐精选

Keevx

Keevx

AI数字人视频创作平台

Keevx 一款开箱即用的AI数字人视频创作平台,广泛适用于电商广告、企业培训与社媒宣传,让全球企业与个人创作者无需拍摄剪辑,就能快速生成多语言、高质量的专业视频。

即梦AI

即梦AI

一站式AI创作平台

提供 AI 驱动的图片、视频生成及数字人等功能,助力创意创作

扣子-AI办公

扣子-AI办公

AI办公助手,复杂任务高效处理

AI办公助手,复杂任务高效处理。办公效率低?扣子空间AI助手支持播客生成、PPT制作、网页开发及报告写作,覆盖科研、商业、舆情等领域的专家Agent 7x24小时响应,生活工作无缝切换,提升50%效率!

TRAE编程

TRAE编程

AI辅助编程,代码自动修复

Trae是一种自适应的集成开发环境(IDE),通过自动化和多元协作改变开发流程。利用Trae,团队能够更快速、精确地编写和部署代码,从而提高编程效率和项目交付速度。Trae具备上下文感知和代码自动完成功能,是提升开发效率的理想工具。

AI工具TraeAI IDE协作生产力转型热门
蛙蛙写作

蛙蛙写作

AI小说写作助手,一站式润色、改写、扩写

蛙蛙写作—国内先进的AI写作平台,涵盖小说、学术、社交媒体等多场景。提供续写、改写、润色等功能,助力创作者高效优化写作流程。界面简洁,功能全面,适合各类写作者提升内容品质和工作效率。

AI辅助写作AI工具蛙蛙写作AI写作工具学术助手办公助手营销助手AI助手
问小白

问小白

全能AI智能助手,随时解答生活与工作的多样问题

问小白,由元石科技研发的AI智能助手,快速准确地解答各种生活和工作问题,包括但不限于搜索、规划和社交互动,帮助用户在日常生活中提高效率,轻松管理个人事务。

热门AI助手AI对话AI工具聊天机器人
Transly

Transly

实时语音翻译/同声传译工具

Transly是一个多场景的AI大语言模型驱动的同声传译、专业翻译助手,它拥有超精准的音频识别翻译能力,几乎零延迟的使用体验和支持多国语言可以让你带它走遍全球,无论你是留学生、商务人士、韩剧美剧爱好者,还是出国游玩、多国会议、跨国追星等等,都可以满足你所有需要同传的场景需求,线上线下通用,扫除语言障碍,让全世界的语言交流不再有国界。

讯飞智文

讯飞智文

一键生成PPT和Word,让学习生活更轻松

讯飞智文是一个利用 AI 技术的项目,能够帮助用户生成 PPT 以及各类文档。无论是商业领域的市场分析报告、年度目标制定,还是学生群体的职业生涯规划、实习避坑指南,亦或是活动策划、旅游攻略等内容,它都能提供支持,帮助用户精准表达,轻松呈现各种信息。

AI办公办公工具AI工具讯飞智文AI在线生成PPTAI撰写助手多语种文档生成AI自动配图热门
讯飞星火

讯飞星火

深度推理能力全新升级,全面对标OpenAI o1

科大讯飞的星火大模型,支持语言理解、知识问答和文本创作等多功能,适用于多种文件和业务场景,提升办公和日常生活的效率。讯飞星火是一个提供丰富智能服务的平台,涵盖科技资讯、图像创作、写作辅助、编程解答、科研文献解读等功能,能为不同需求的用户提供便捷高效的帮助,助力用户轻松获取信息、解决问题,满足多样化使用场景。

热门AI开发模型训练AI工具讯飞星火大模型智能问答内容创作多语种支持智慧生活
Spark-TTS

Spark-TTS

一种基于大语言模型的高效单流解耦语音令牌文本到语音合成模型

Spark-TTS 是一个基于 PyTorch 的开源文本到语音合成项目,由多个知名机构联合参与。该项目提供了高效的 LLM(大语言模型)驱动的语音合成方案,支持语音克隆和语音创建功能,可通过命令行界面(CLI)和 Web UI 两种方式使用。用户可以根据需求调整语音的性别、音高、速度等参数,生成高质量的语音。该项目适用于多种场景,如有声读物制作、智能语音助手开发等。

下拉加载更多