Cassandra中的InvalidRequestException
贝凯
问题内容：
问题答案：
两天前，我开始在实习期间学习Cassandra，他们让我对Cassandra有了一些了解，我从网上找到了一些代码。这些代码在语法上没有错误，但是当我运行代码时，出现了类似以下错误：
org.apache.cassandra.thrift.Cassandra $
Client.recv_remove（）上的InvalidRequestException（为什么：键空间博客在此架构中不存在。）位于org.apache.cassandra.thrift.Cassandra
$ remove_result.read（Cassandra.java:14354）
org.apache.cassandra.thrift.Cassandra $
Client.remove（Cassandra.java:729）处的org.apache.cassandra.thrift.Cassandra $
Client.remove（Cassandra.java:729）处的Authors.removeAuthor（Authors.java:141）处的Authors.main（Authors.java:59）
我还使用./cassandra
-f命令从控制台运行cassandra。我认为我首先需要建立一个cassandra数据库，但是我真的找不到如何用Java来做。请帮助我这个话题。非常感谢你。
如果这会有所帮助，我正在尝试的代码在这里。
/**
* Sample code for the blog posting:
*
* Installing and using Apache Cassandra With Java Part 4 (Thrift Client)
* http://www.sodeso.nl/?p=251
*
* Please report any discrepancies that you may find,
* if you have any requests for examples not mentioned here
* but are within the scope of the blog posting then also
* please let me know so i can add them..
*/
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.cassandra.thrift.Cassandra;
import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnOrSuperColumn;
import org.apache.cassandra.thrift.ColumnParent;
import org.apache.cassandra.thrift.ColumnPath;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.Deletion;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.thrift.KeyRange;
import org.apache.cassandra.thrift.KeySlice;
import org.apache.cassandra.thrift.Mutation;
import org.apache.cassandra.thrift.NotFoundException;
import org.apache.cassandra.thrift.SlicePredicate;
import org.apache.cassandra.thrift.SliceRange;
import org.apache.cassandra.thrift.TimedOutException;
import org.apache.cassandra.thrift.UnavailableException;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
/**
* @author Ronald Mathies
*/
public class Authors {
private static final String KEYSPACE = "Blog";
private static final String COLUMN_FAMILY = "Authors";
public static final String ENCODING = "utf-8";
private static TTransport tr = null;
public static void main(String[] args) throws TException, InvalidRequestException, UnavailableException, UnsupportedEncodingException, NotFoundException, TimedOutException {
Cassandra.Client client = setupConnection();
System.out.println("Remove all the authors we might have created before.\n");
removeAuthor(client, "Eric Long");
removeAuthor(client, "Ronald Mathies");
removeAuthor(client, "John Steward");
System.out.println("Create the authors.\n");
createAuthor(client, "Eric Long", "eric (at) long.com", "United Kingdom", "01/01/2002");
createAuthor(client, "Ronald Mathies", "ronald (at) sodeso.nl", "Netherlands, The", "01/01/2010");
createAuthor(client, "John Steward", "john.steward (at) somedomain.com", "Australia", "01/01/2009");
System.out.println("Select Eric Long.\n");
selectSingleAuthorWithAllColumns(client, "Eric Long");
System.out.println("Select Ronald Mathies.\n");
selectSingleAuthorWithAllColumns(client, "Ronald Mathies");
System.out.println("Select John Steward.\n");
selectSingleAuthorWithAllColumns(client, "John Steward");
System.out.println("Select all authors with all columns.\n");
selectAllAuthorsWithAllColumns(client);
System.out.println("Select all authors with only the email column.\n");
selectAllAuthorsWithOnlyTheEmailColumn(client);
System.out.println("Update John Steward.\n");
updateJohnStewardAuthor(client);
System.out.println("Select John Steward.\n");
selectSingleAuthorWithAllColumns(client, "John Steward");
System.out.println("Remove email address and birthday from John Steward.\n");
deleteEmailAndBirthdayFromJohnSteward(client);
System.out.println("Select John Steward.\n");
selectSingleAuthorWithAllColumns(client, "John Steward");
closeConnection();
}
/**
* Open up a new connection to the Cassandra Database.
*
* @return the Cassandra Client
*/
private static Cassandra.Client setupConnection() throws TTransportException {
try {
tr = new TSocket("localhost", 9160);
TProtocol proto = new TBinaryProtocol(tr);
Cassandra.Client client = new Cassandra.Client(proto);
tr.open();
return client;
} catch (TTransportException exception) {
exception.printStackTrace();
}
return null;
}
/**
* Close the connection to the Cassandra Database.
*/
private static void closeConnection() {
try {
tr.flush();
tr.close();
} catch (TTransportException exception) {
exception.printStackTrace();
}
}
/**
* Removes an Author from the Authors ColumnFamily.
* cccc
* @param client the Corg.apache.thrift;
importassandra Client
* @param authorKey The key of the Author
*/
private static void removeAuthor(Cassandra.Client client, String authorKey) {
try {
ColumnPath columnPath = new ColumnPath(COLUMN_FAMILY);
client.remove(KEYSPACE, authorKey, columnPath, System.currentTimeMillis(), ConsistencyLevel.ALL);
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Creates and stores an Author in the Cassandra Database.
*
* @param client the Cassandra Client
* @param authorKey The key of the Author
* @param email the email address
* @param country the country
* @param registeredSince the registration date
*/
private static void createAuthor(Cassandra.Client client, String authorKey, String email, String country, String registeredSince) {
try {
long timestamp = System.currentTimeMillis();
Map<String, List<ColumnOrSuperColumn>> job = new HashMap<String, List<ColumnOrSuperColumn>>();
List<ColumnOrSuperColumn> columns = new ArrayList<ColumnOrSuperColumn>();
Column column = new Column("email".getBytes(ENCODING), email.getBytes(ENCODING), timestamp);
ColumnOrSuperColumn columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
columns.add(columnOrSuperColumn);
column = new Column("country".getBytes(ENCODING), country.getBytes(ENCODING), timestamp);
columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
columns.add(columnOrSuperColumn);
column = new Column("country".getBytes(ENCODING), country.getBytes(ENCODING), timestamp);
columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
columns.add(columnOrSuperColumn);
column = new Column("registeredSince".getBytes(ENCODING), registeredSince.getBytes(ENCODING), timestamp);
columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
columns.add(columnOrSuperColumn);
job.put(COLUMN_FAMILY, columns);
client.batch_insert(KEYSPACE, authorKey, job, ConsistencyLevel.ALL);
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Selects a single author with all the columns from the Cassandra database
* and display it in the console.
*
* @param client the Cassandra client
* @param authorKey The key of the Author
*/
private static void selectSingleAuthorWithAllColumns(Cassandra.Client client, String authorKey) {
try {
SlicePredicate slicePredicate = new SlicePredicate();
SliceRange sliceRange = new SliceRange();
sliceRange.setStart(new byte[] {});
sliceRange.setFinish(new byte[] {});
slicePredicate.setSlice_range(sliceRange);
ColumnParent columnParent = new ColumnParent(COLUMN_FAMILY);
List<ColumnOrSuperColumn> result = client.get_slice(KEYSPACE, authorKey, columnParent, slicePredicate, ConsistencyLevel.ONE);
printToConsole(authorKey, result);
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Selects all the authors with all the columns from the Cassandra database.
*
* @param client the Cassandra client
*/
private static void selectAllAuthorsWithAllColumns(Cassandra.Client client) {
try {
KeyRange keyRange = new KeyRange(3);
keyRange.setStart_key("");
keyRange.setEnd_key("");
SliceRange sliceRange = new SliceRange();
sliceRange.setStart(new byte[] {});
sliceRange.setFinish(new byte[] {});
SlicePredicate slicePredicate = new SlicePredicate();
slicePredicate.setSlice_range(sliceRange);
ColumnParent columnParent = new ColumnParent(COLUMN_FAMILY);
List<KeySlice> keySlices = client.get_range_slices(KEYSPACE, columnParent, slicePredicate, keyRange, ConsistencyLevel.ONE);
for (KeySlice keySlice : keySlices) {
printToConsole(keySlice.getKey(), keySlice.getColumns());
}
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Selects all the authors with only the email column from the Cassandra
* database.
*
* @param client the Cassandra client
*/
private static void selectAllAuthorsWithOnlyTheEmailColumn(Cassandra.Client client) {
try {
KeyRange keyRange = new KeyRange(3);
keyRange.setStart_key("");
keyRange.setEnd_key("");
List<byte[]> columns = new ArrayList<byte[]>();
columns.add("email".getBytes(ENCODING));
SlicePredicate slicePredicate = new SlicePredicate();
slicePredicate.setColumn_names(columns);
ColumnParent columnParent = new ColumnParent(COLUMN_FAMILY);
List<KeySlice> keySlices = client.get_range_slices(KEYSPACE, columnParent, slicePredicate, keyRange, ConsistencyLevel.ONE);
for (KeySlice keySlice : keySlices) {
printToConsole(keySlice.getKey(), keySlice.getColumns());
}
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Update the John Steward author with a new email address and a new field, the birthday.
*
* @param client the Cassandra client
*/
private static void updateJohnStewardAuthor(Cassandra.Client client) {
try {
long timestamp = System.currentTimeMillis();
Map<String, Map<String, List<Mutation>>> job = new HashMap<String, Map<String, List<Mutation>>>();
List<Mutation> mutations = new ArrayList<Mutation>();
// Change the email address
Column column = new Column("email".getBytes(ENCODING), "john@steward.nl".getBytes(ENCODING), timestamp);
ColumnOrSuperColumn columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
Mutation mutation = new Mutation();
mutation.setColumn_or_supercolumn(columnOrSuperColumn);
mutations.add(mutation);
// Add a new column
column = new Column("birthday".getBytes(ENCODING), "05-04-1978".getBytes(ENCODING), timestamp);
columnOrSuperColumn = new ColumnOrSuperColumn();
columnOrSuperColumn.setColumn(column);
mutation = new Mutation();
mutation.setColumn_or_supercolumn(columnOrSuperColumn);
mutations.add(mutation);
Map<String, List<Mutation>> mutationsForColumnFamily = new HashMap<String, List<Mutation>>();
mutationsForColumnFamily.put(COLUMN_FAMILY, mutations);
job.put("John Steward", mutationsForColumnFamily);
client.batch_mutate(KEYSPACE, job, ConsistencyLevel.ALL);
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Delete the email address and birthday from John Steward.
*
* @param client the Cassandra client
*/
private static void deleteEmailAndBirthdayFromJohnSteward(Cassandra.Client client) {
try {
long timestamp = System.currentTimeMillis();
// The columns we want to remove
List<byte[]> columns = new ArrayList<byte[]>();
columns.add("email".getBytes(ENCODING));
columns.add("birthday".getBytes(ENCODING));
// Add the columns to a SlicePredicate
SlicePredicate slicePredicate = new SlicePredicate();
slicePredicate.setColumn_names(columns);
Deletion deletion = new Deletion(timestamp);
deletion.setPredicate(slicePredicate);
Mutation mutation = new Mutation();
mutation.setDeletion(deletion);
List<Mutation> mutations = new ArrayList<Mutation>();
mutations.add(mutation);
Map<String, List<Mutation>> mutationsForColumnFamily = new HashMap<String, List<Mutation>>();
mutationsForColumnFamily.put(COLUMN_FAMILY, mutations);
Map<String, Map<String, List<Mutation>>> batch = new HashMap<String, Map<String, List<Mutation>>>();
batch.put("John Steward", mutationsForColumnFamily);
client.batch_mutate(KEYSPACE, batch, ConsistencyLevel.ALL);
} catch (Exception exception) {
exception.printStackTrace();
}
}
/**
* Prints out the information to the console.
*
* @param key the key of the Author
* @param result the result to print out
*/
private static void printToConsole(String key, List<ColumnOrSuperColumn> result) {
try {
System.out.println("Key: '" + key + "'");
for (ColumnOrSuperColumn c : result) {
if (c.getColumn() != null) {
String name = new String(c.getColumn().getName(), ENCODING);
String value = new String(c.getColumn().getValue(), ENCODING);
long timestamp = c.getColumn().getTimestamp();
System.out.println(" name: '" + name + "', value: '" + value + "', timestamp: " + timestamp);
} else {
}
}
} catch (UnsupportedEncodingException exception) {
exception.printStackTrace();
}
}
}
问题答案：
“键空间X不存在”表示…键空间不存在。在您的storage-conf.xml中配置了键空间。
除此之外，手动创建KeySpace并与Thrift客户端与cassandra连接。它的示例在cassandra Wiki网页中给出。
类似资料：
-
我正在将一个应用程序从Cassandra迁移到Dynamodb。在Cassandra上，我们使用了(entityName、TimeUUID)和DynamoDB的组合作为键，据我所知，我可以使用hash+range主键。 为了使Cassandra数据库具有相同的数据结构，我一直在考虑使用entityName作为散列，使用timestamp作为范围。然后，我认为时间戳可能不是唯一的：我说的是拐角情况，
-
我的理解是，行键只不过是分区键，即日、小时列组成行键。 我的理解正确吗？有人能澄清这一点吗？
-
你说的批处理语句在卡桑德拉中是原子的是什么意思？确切地说，文档在本质上有点令人困惑。这是否意味着查询在群集中的节点之间是原子的？ 例如，我有一批100个查询。如果批处理中的第40个查询失败，那么批处理中执行的39个查询会发生什么？ 我知道有一个在后台创建的批处理日志，它将负责部分批处理的一致性。它是否删除了其余39个条目，并提供了批处理查询所需的原子性质。 在MYSQL中，我们将自动提交设置为fa
-
我猜它看起来是： 因此，本质上，我可以为给定的行拥有一堆时间戳，为一行拥有一个UUID。对于TS列的每次新插入，都需要更新UUID。 所以插入一行就可以了： 我正试图找出如何正确地对数据建模，以便每行只有一个UUID，并且可以有多个列，而不必在表创建期间显式地定义它们，因为它可能会有很大的变化。 IIRC，使用thrift客户机很容易做到这一点，但使用它不是一个选项=/
-
我已经在带有JDK 1.8的Linux m / c上安装了 2.2.5。 现在，我使用< code > spring-Cassandra-data jar中提供的< code>CassandraTemplate在< code>Cassandra DB中插入记录。 但是，时间戳被转换为GMT，即在存储在数据库中之前从中扣除5：30小时。 我希望实际时间戳存储在数据库中。 先谢谢你。