Вызовите cql sh в python сценарии, чтобы выполнить файл, указанный в опции -f в cassandra

Question

Как вызвать скрипт cql sh в python для выполнения запросов в Кассандре?

Спасибо, Имран Хан

Answer 1

Вы должны быть в состоянии сделать это с библиотекой subprocess:

import subprocess
import sys

hostname=sys.argv[1]
username=sys.argv[2]
password=sys.argv[3]

strFile = "myCommands.cql"
process = subprocess.Popen("/usr/local/apache-cassandra-3.1.4/bin/cqlsh {0} -u {1} -p {2} -f {3} ;".format(hostname,username,password,strFile), shell=True)
exitCode = process.wait()

Попробуйте. Я сделал нечто подобное для автоматизации функциональности COPY TO / FROM.

Обратите внимание, что в вашем командном файле cql команды должны заканчиваться точкой с запятой (;), как и вы будет в пределах cql sh.

Answer 2

Мы можем использовать cassandra-driver как любой другой драйвер БД в python для выполнения cql sh.

или

import cql
con= cql.connect(host="server",port=port,keyspace="keyspace")
cur=con.cursor()
result=cur.execute("select * from table")