DSE 使用 Bulk Loader 加载数据
DSE Loading Data using Bulk Loader
目前,我已经通过使用OpsCenter成功安装了必要的节点和数据中心。
我还通过 DataStax Studio 使用 Cassandra 生成了必要的 table 和 Keyspace
KeySpace 已生成
CREATE KEYSPACE graph_tables WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':1};
Table 已生成
CREATE TABLE people_node (id text, name text, age int, location 'PointType', gender text, dob timestamp, PRIMARY KEY(id));
示例数据
id, name , age, location, gender, dob
0, Betsy, 15 , 10 15 , F , 1997-09-21T12:55:54
假设我们有一个 node_1,IP 地址为 1.1.1.1,第二个节点名为 node_2,IP 地址为 2.2.2.2。这些将是 OpsCenter 在
上安装 Cassandra 的两个节点
从这里开始,我尝试使用 dsbulk
插入必要的数据
dsbulk load -url ./people_node_csv -k graph_tables -t people_node -h '1.1.1.1, 2.2.2.2 ' -header true
但是,这会导致错误 "Operation Load_..... failed: Authentication error on host /1.1.1.1:9042: Host /1.1.1.1:9042 requires authentication, but no authenticator found in Cluster Configurations"。我试图通过添加 "driver.ssl.keystone.password = cassandra" 来解决这个问题,如 Document 所示。但错误仍然存在。任何有关解决此问题的建议将不胜感激。
您需要按照 documentation 中的说明提供以下设置:
-u
- 指定用户名
-p
- 指定密码
--driver.auth.provider DsePlainTextAuthProvider
- 到 select 相应的身份验证提供程序。
目前,我已经通过使用OpsCenter成功安装了必要的节点和数据中心。
我还通过 DataStax Studio 使用 Cassandra 生成了必要的 table 和 Keyspace
KeySpace 已生成
CREATE KEYSPACE graph_tables WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':1};
Table 已生成
CREATE TABLE people_node (id text, name text, age int, location 'PointType', gender text, dob timestamp, PRIMARY KEY(id));
示例数据
id, name , age, location, gender, dob
0, Betsy, 15 , 10 15 , F , 1997-09-21T12:55:54
假设我们有一个 node_1,IP 地址为 1.1.1.1,第二个节点名为 node_2,IP 地址为 2.2.2.2。这些将是 OpsCenter 在
上安装 Cassandra 的两个节点从这里开始,我尝试使用 dsbulk
插入必要的数据dsbulk load -url ./people_node_csv -k graph_tables -t people_node -h '1.1.1.1, 2.2.2.2 ' -header true
但是,这会导致错误 "Operation Load_..... failed: Authentication error on host /1.1.1.1:9042: Host /1.1.1.1:9042 requires authentication, but no authenticator found in Cluster Configurations"。我试图通过添加 "driver.ssl.keystone.password = cassandra" 来解决这个问题,如 Document 所示。但错误仍然存在。任何有关解决此问题的建议将不胜感激。
您需要按照 documentation 中的说明提供以下设置:
-u
- 指定用户名-p
- 指定密码--driver.auth.provider DsePlainTextAuthProvider
- 到 select 相应的身份验证提供程序。