Apache Cassandra 连接¶
Apache Cassandra 连接类型允许连接到 Apache Cassandra。
默认连接 ID¶
Cassandra 钩子和 Cassandra 操作符默认使用 cassandra_default。
配置连接¶
- 主机（必填）
要连接的主机。可以将多个主机指定为逗号分隔的列表。
- 模式（必填）
要在数据库中使用的模式（键空间）名称。
- 登录名（必填）
用于连接的用户名。
- 密码（必填）
用于连接的密码。
- 端口（必填）
要连接的端口。
- 额外参数（可选）
可以在 Cassandra 连接中使用的额外参数（作为 JSON 字典）。支持以下标准 Python 参数之外的参数
load_balancing_policy- 此参数指定要使用的负载均衡策略。有四种可用策略：RoundRobinPolicy、DCAwareRoundRobinPolicy、WhiteListRoundRobinPolicy和TokenAwarePolicy。RoundRobinPolicy是默认的负载均衡策略。load_balancing_policy_args- 此参数指定正在使用的负载均衡策略的参数。cql_version- 此参数指定 Cassandra 的 CQL 版本。protocol_version- 此参数指定要使用的本机协议的最大版本。ssl_options- 如果在 Cassandra 中启用了 SSL，则此参数指定与 SSL 相关的详细信息。
**额外参数** 字段的示例¶
指定
ssl_options
如果在 Cassandra 中启用了 SSL，请在额外参数字段中传入一个字典作为 ssl.wrap_socket() 的 kwargs。例如
{
"ssl_options": {
"ca_certs": "PATH/TO/CA_CERTS"
}
}
指定
load_balancing_policy和load_balancing_policy_args
默认的负载均衡策略是 RoundRobinPolicy。以下是一些指定不同负载均衡策略的示例
DCAwareRoundRobinPolicy
{
"load_balancing_policy": "DCAwareRoundRobinPolicy",
"load_balancing_policy_args": {
"local_dc": "LOCAL_DC_NAME",
"used_hosts_per_remote_dc": "SOME_INT_VALUE"
}
}
WhiteListRoundRobinPolicy
{
"load_balancing_policy": "WhiteListRoundRobinPolicy",
"load_balancing_policy_args": {
"hosts": ["HOST1", "HOST2", "HOST3"]
}
}
TokenAwarePolicy
{
"load_balancing_policy": "TokenAwarePolicy",
"load_balancing_policy_args": {
"child_load_balancing_policy": "CHILD_POLICY_NAME",
"child_load_balancing_policy_args": {}
}
}