jeffharwell/cassandra-lucene

cassandra-lucene镜像

概述

该Docker镜像基于launcher.gcr.io/google/cassandra3:3.11，使用Cassandra 3.11.3版本，并集成了Stratio Cassandra Lucene Index插件（版本3.11.1.0）。它旨在替代Kubernetes示例《使用Stateful Sets部署Cassandra》中的gcr.io/google-samples/cassandra:v12镜像，插件编译遵循Stratio Cassandra Lucene Index项目（3.9.0分支）的官方文档。

核心功能

• 提供Cassandra 3.11.3的基础数据库功能
• 支持Lucene-based全文搜索、地理空间搜索等高级查询能力
• 可无缝替换指定Kubernetes示例中的官方Cassandra镜像

使用场景

• Kubernetes环境下Cassandra Stateful Sets集群的测试与演示
• 开发/测试环境中快速验证带Lucene索引的Cassandra数据查询功能

测试与演示

脚本测试

执行测试脚本：sh ./test_with_cqlsh.sh
该脚本利用官方Cassandra容器的cqlsh工具连接到本镜像实例，自动创建测试数据并验证索引功能。

手动测试步骤

1. 运行镜像实例（示例命令）：

bash
docker run -d --name cassandra-lucene jeffharwell/cassandra-lucene

2. 使用官方Cassandra容器的cqlsh连接：

bash
docker run -it --link cassandra-lucene:cassandra --rm cassandra cqlsh cassandra

3. 执行CQL命令创建测试数据与索引：

cql
CREATE KEYSPACE demo WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor':1};
USE demo;
CREATE TABLE tweets (id INT PRIMARY KEY, user TEXT, body TEXT, time TIMESTAMP, latitude FLOAT, longitude FLOAT);

CREATE CUSTOM INDEX tweets_index ON tweets () 
USING 'com.stratio.cassandra.lucene.Index' 
WITH OPTIONS = {
   'refresh_seconds': '1',
   'schema': '{
      fields: {
         id: {type: "integer"},
         user: {type: "string"},
         body: {type: "text", analyzer: "english"},
         time: {type: "date", pattern: "yyyy/MM/dd"},
         place: {type: "geo_point", latitude: "latitude", longitude: "longitude"}
      }
   }'
};

INSERT INTO tweets (id, body) VALUES (1, 'this is a test');
INSERT INTO tweets (id, body) VALUES (2, 'this is also a test record');
INSERT INTO tweets (id, body) VALUES (3, 'this one does not use that word');

4. 等待1秒后执行查询：

cql
SELECT * FROM tweets WHERE expr(tweets_index, '{query: {type: "phrase", field: "body", value: "test", slop:1}}') LIMIT 100;

预期返回id为1和2的记录。