Kết nối python với cassandra một cụm từ cửa sổ với DseAuthenticator và DseAuthorizer

Question

Tôi đã thử cả hai với pycassa, cassandra.cluster và dse.cluster mà không cần thực hiện kết nối.

Tôi cảm thấy mình đang kết nối với máy chủ không đúng, vì tôi đang viết tên máy chủ của máy chủ Linux và không chỉ định bất kỳ điều gì liên quan đến cassandra.

Collegues đã nói với tôi rằng họ chỉ biết kết nối với máy chủ thông qua cqlsh nội tuyến trên máy linux. Điều đó nghe có vẻ không tiện lợi.

cấu hình cụ thể trong cassandra.yaml

authenticator: com.datastax.bdp.cassandra.auth.DseAuthenticator 
authorizer: com.datastax.bdp.cassandra.auth.DseAuthorizer 

Những gì tôi đang làm trong pycassa: Thông điệp

import pycassa 
URIPORTLIST = ['12345.mycompany.net:9420'] 
pool = pycassa.ConnectionPool('my_keyspace', server_list=URIPORTLIST,credentials={'USERNAME':'fancycar','PASSWORD':'becauseimbatman'}, prefill=False) 
cf = pycassa.ColumnFamily(pool, 'my_table') 

Lỗi:

AllServersUnavailable: An attempt was made to connect to each of the servers twice, but none of the attempts succeeded. The last failure was TTransportException: Could not connect to 12345.mycompany.net:9420 

Với dse.cluster

from dse.cluster import Cluster 
auth_provider = PlainTextAuthProvider(
     username='fancycar', password='becauseimbatman') 
cluster = Cluster(
    ['12345.mycompany.net'], 
    port=9042,auth_provider=auth_provider) 
session = cluster.connect('my_keyspace') 

nhắn

Lỗi:

NoHostAvailable: ('Unable to connect to any servers', {'11.111.11.1': AuthenticationFailed('Failed to authenticate to 11.111.11.2: Error from server: code=0100 [Bad credentials] message="Failed to login. Please re-try."',)}) 

Answer 1

Cố định bằng công PlainTextAuthProvider dse.auth thay cho Cassandra một ..

from dse.cluster import Cluster 
# pip install dse-driver 
from dse.auth import PlainTextAuthProvider 
auth_provider = PlainTextAuthProvider(
     username='fancycar', password='becauseimbatman ') 
cluster = Cluster(contact_points=['12345.mycompany.net'], 
port=9042, auth_provider=auth_provider) 
session = cluster.connect('batcave') 
print "connected" 
print session.execute("SELECT * FROM robinstears")[0]