- OpenJDK 8 ou Oracle Java Platform, Standard Edition 8 (JDK).
- Python 2.7 para uso do cqlsh.
- Docker
-
Crie um container DSE com a Pesquisa ativada:
user@user:~$ docker pull datastax/dse-server:6.8.0
user@user:~$ docker run -e DS_LICENSE=accept --name demo-dse -p 9042:9042 -d datastax/dse-server:6.8.0 -s -R
- Mais orientações podem ser encontradas Aqui
-
Crie um container DSE-Studio:
user@user:~$ docker pull datastax/dse-studio:6.8.0
user@user:~$ docker run -e DS_LICENSE=accept --name my-studio -p 9091:9091 -d datastax/dse-studio:6.8.0 --link demo-dse
- Mais orientações podem ser encontradas Aqui
-
Para poder administrar o banco de dados:
user@user:~$ docker exec -it demo-dse cqlsh
-
Criando keyspace e tabela:
cqlsh> CREATE KEYSPACE IF NOT EXISTS ep9cas001 WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy', 'dc1' : 2 }; cqlsh> USE ep9cas001; cqlsh:ep9cas001> CREATE TABLE ep9cas001.tb_user ( id uuid, name text, gender text, birthday timestamp, city text, PRIMARY KEY (id) );
-
Importe os dados para simular a carga do banco:
-
A carga de dados em data.csv possui um milhão de linhas para serem importadas.
-
Primeiro precisamos copiar os dados de
data.csvpara o container:user@user:~$ docker cp `caminho completo`/cassandra-stress/data.csv demo-dse:/home/data.csv
-
Com os dados no container execute:
cqlsh> USE ep9cas001; cqlsh:ep9cas001> COPY ep9cas001.tb_user(id, name, gender, birthday, city) FROM '/home/data.csv' WITH DELIMITER = ',' AND HEADER = TRUE;
-
Se a importação for realizada com sucesso, aparece a seguinte mensagem:
Processed: 1000000 rows; Rate: 6850 rows/s; Avg. rate: 17392 rows/s 1000000 rows imported from 1 files in 57.500 seconds (0 skipped).
-
-
Criando os índices de pesquisa:
cqlsh> USE ep9cas001; cqlsh:ep9cas001> CREATE SEARCH INDEX IF NOT EXISTS ON ep9cas001.tb_user WITH COLUMNS name {docValues:true}, gender {docValues:true}, birthday {docValues:true}, city {docValues:true, excluded : false};
-
Subindo a aplicação:
-
Basta clonar o projeto:
user@user:~$ git clone https://github.com/RafaelOFreitas/cassandra-stress.git
-
Importe o projeto na IDE como um projeto Maven.
-
Caso as dependências maven não sejam importadas automaticamente, na pasta do projeto executar:
user@user:~$ mvn clean install
-
-
Exemplo de Requisição:
-
Filtre uma consulta CQL usando a solr_query:
-
Exemplo de Query Solr para ordenação de campo com
docValues:true:cqlsh:ep9cas001> SELECT * FROM ep9cas001.tb_user WHERE solr_query='{"q":"*:*", "sort":"name asc"}' LIMIT 10;
-
Exemplo de Query Solr para buscas de campos compostos:
cqlsh:ep9cas001> SELECT * FROM ep9cas001.tb_user where solr_query='{"q":"*:*", "fq":"name:Gordon\\ Sanders"}' LIMIT 1;
-
Exemplo de Query Solr para range de datas:
cqlsh:ep9cas001> SELECT * FROM ep9cas001.tb_user WHERE solr_query = 'birthday:[2014-06-15T00:00:00Z TO 2017-02-02T00:00:00Z]';
-
Exemplo de Query Solr para paginação:
cqlsh:ep9cas001> SELECT * FROM ep9cas001.tb_user WHERE solr_query='{"q": "gender:Male", "start":"0"}' LIMIT 10;
cqlsh:ep9cas001> SELECT * FROM ep9cas001.tb_user WHERE solr_query='{"q": "gender:Male", "start":"10"}' LIMIT 10;
-
-
Testes (
interval (ms) 300):-
200 usuários por filtro
1.000 req:
-
2.000 usuários por filtro
10.000 req:
-
20.000 usuários
20.000 req:
-
10.000 usuários por filtro
50.000 req:
-
-
Pesquisas:
