<div id="readability-page-1" class="page"><div id="SE-f398da73-20ef-446d-a4a9-5408e9ee9357">
 안녕하세요 멍개입니다.​지난 시간에 카산드라를 다뤄보았습니다. 이번 시간은 카산드라와 완벽하게 호환되는 scylladb를 다뤄보겠습니다. scylladb는 카산드라와 완벽하게 호환되기 때문에 다음 글을 먼저 읽고오는것을 추천드립니다.<a href="https://blog.naver.com/pjt3591oo/223972257259" data-linktype="text" data-linkdata="{&quot;id&quot;: &quot;SE-edaa1ded-ddf0-4f54-b86b-a006eebf8a72&quot;, &quot;link&quot;: &quot;https://blog.naver.com/pjt3591oo/223972257259&quot;}" target="_blank">https://blog.naver.com/pjt3591oo/223972257259</a>
 </div><div id="SE-1935332d-8c1b-47bc-886f-ce55ce2c816d">
 ● 카산드라와 scylladb 비교scylladb는 카산드라와 완벽한 호환이 되기 때문에 비슷한 형태로 동작하지만 미묘하게 다른 부분이 존재합니다. 하지만 동작 메커니즘 자체는 동일합니다.​· 언어적 차이scylladb와 카산드라의 가장 차이점은 작성된 언어입니다. 카산드라는 Java 기반으로 동작을 합니다. 하지만 scylladb는 c++로 작성되어 있으며, 작성된 언어만 봐도 scylladb가 왜 빠른지 알 수 있습니다. 카산드라의 경우 GC로 인해 성능 저하가 존재합니다.​· 리소스 효율성카산드라는 쓰레드 풀 모델을 이용합니다.​scylladb는 CPU코어 수 만큼의 쓰레드를 가지면 각 쓰레드는 별도의 메모리 풀과 큐를 가집니다.
 </div><div id="SE-13d55e52-6ff4-4a99-a2c2-ebf55084e33b">
 · Gossip Dancescylladb와 카산드라는 gossip 프로토콜을 이용하여 서로의 상태를 공유받습니다. 분산된 환경에서 랜덤하게 선택된 노드들이 서로 패킷을 주고 받으며 상태를 확인하는 모습을 Gossip Dance라고 부릅니다.​카산드라 4.0부터 경우 P2P 통신을 위해 Netty를 이용한 Non-blocking I/O를 제공한다고 합니다.
 </div><div id="SE-07fa516c-4303-46a2-921e-50fcc1534d93">
 · 데이터 삭제를 위한 톰스톤카산드라와 scylladb는 모두 delete 요청이 발생하면 실제 데이터를 직접 삭제하지 않고 톰스톤을 생성 후 다른 노드에게 전파합니다.​두 디비 모두 데이터가 SSTable에 다음과 같은 형태로 저장되어 있습니다.
 </div><div id="SE-84ba02e6-c806-4142-8b33-d4c0b6e7c28b">
 다음과 같이 DELETE가 실행될 수 있습니다.
 </div><div id="SE-99384fb8-998b-4702-88b2-dda3bc51a21f">
 SSTable은 다음과 같이 TOMBSTONE이 추가됩니다.
 </div><div id="SE-04a2f5e0-e36d-4e39-a531-89e08aff08a8">
 이 케이스에서 Key가 123인 요소를 읽었을 때 timestamp를 비교하여 원본 데이터의 timestamp보다 추가된 톰스톤의 timestamp가 더 크다면 조회 결과에 포함시키지 않습니다.(데이터가 바로 삭제되지 않고 톰스톤의 타임스탬프와 비교되는 과정이 있기 때문에 삭제가 자주 일어날 경우 성능 저하가 발생될 수 있습니다)​설정된 gc_grace_seconds에 따라 Compaction 과정을 진행합니다. 톰스톤과 원본 데이터를 모두 확인하여 오래된 톰스톤과 원본 데이터 모두 삭제합니다.​● 아키텍처stylladb는 공식문서에서 아키텍처를 보여주고 있습니다.<a href="https://opensource.docs.scylladb.com/stable/architecture/index.html" data-linktype="text" data-linkdata="{&quot;id&quot;: &quot;SE-59b3fb24-936e-4da1-9b70-7633e08af005&quot;, &quot;link&quot;: &quot;https://opensource.docs.scylladb.com/stable/architecture/index.html&quot;}" target="_blank">https://opensource.docs.scylladb.com/stable/architecture/index.html</a>
 </div><div id="SE-62f084f5-798a-4410-80d3-391e475c06b1">
 ​· 클라이언트 - 서버 아키텍처scylladb는 카산드라와 완전하게 호환되는 CQL을 이용하기 때문에 카산드라에서 사용하는 드라이버를 그대로 이용할 수 있습니다. 또한 AWS DynamoDB 드라이버로도 이용가능합니다.<a href="https://opensource.docs.scylladb.com/stable/using-scylla/drivers/dynamo-drivers/index.html" data-linktype="text" data-linkdata="{&quot;id&quot;: &quot;SE-e5b5d84d-7674-434f-ae36-7f124ee80092&quot;, &quot;link&quot;: &quot;https://opensource.docs.scylladb.com/stable/using-scylla/drivers/dynamo-drivers/index.html&quot;}" target="_blank">https://opensource.docs.scylladb.com/stable/using-scylla/drivers/dynamo-drivers/index.html</a>
 </div><div id="SE-9611652d-64d6-4ef5-bb6b-5c4c7b638825">
 ​● scylladb 다뤄보기scylladb를 도커 컴포즈를 이용하여 로컬 환경에 구축 후 카산드라 드라이버를 이용하여 CRUD를 수행할 수 있습니다.​· 환경구축
 </div><div id="SE-d616d1d0-6546-481d-ac28-982cd3cda83a">
 scylladb도 노드를 관리하거나 CQL을 수행하는건 카산드라와 동일합니다.​· CRUD 수행
 </div><div id="SE-7f5b65ac-d5df-4ecc-9bf5-8b5a6f57ccaa">
 import cassandra from 'cassandra-driver';

const client = new cassandra.Client({
 contactPoints: ['localhost:9042', 'localhost:9043', 'localhost:9044'],
 localDataCenter: 'datacenter1',
 keyspace: 'test_keyspace',
 policies: {
 loadBalancing: new cassandra.policies.loadBalancing.RoundRobinPolicy()
 }
});

async function createKeyspaceAndTable() {
 try {
 await client.connect();

 await client.execute(`
 CREATE KEYSPACE IF NOT EXISTS test_keyspace
 WITH replication = {
 'class': 'NetworkTopologyStrategy',
 'datacenter1': 2
 }
 `);

 await client.execute('USE test_keyspace');

 await client.execute(`
 CREATE TABLE IF NOT EXISTS users (
 id UUID PRIMARY KEY,
 name TEXT,
 email TEXT,
 age INT,
 created_at TIMESTAMP
 )
 `);
 } catch (error) {
 console.error('Setup error:', error);
 throw error;
 }
}

async function createUser(name, email, age) {
 const id = cassandra.types.Uuid.random();
 const query = `
 INSERT INTO users (id, name, email, age, created_at)
 VALUES (?, ?, ?, ?, ?)
 `;
 const params = [id, name, email, age, new Date()];
 
 try {
 await client.execute(query, params, { prepare: true });
 return id;
 } catch (error) {
 console.error('Create error:', error);
 throw error;
 }
}

async function readUser(id) {
 const query = 'SELECT * FROM users WHERE id = ?';
 
 try {
 const result = await client.execute(query, [id], { prepare: true });
 if (result.rows.length &gt; 0) {
 return result.rows[0];
 } else {
 return null;
 }
 } catch (error) {
 console.error('Read error:', error);
 throw error;
 }
}

async function readAllUsers() {
 const query = 'SELECT * FROM users';
 
 try {
 const result = await client.execute(query);
 result.rows.forEach(row =&gt; {
 });
 return result.rows;
 } catch (error) {
 console.error('Read all error:', error);
 throw error;
 }
}

async function updateUser(id, updates) {
 const setClauses = [];
 const values = [];
 
 if (updates.name) {
 setClauses.push('name = ?');
 values.push(updates.name);
 }
 if (updates.email) {
 setClauses.push('email = ?');
 values.push(updates.email);
 }
 if (updates.age !== undefined) {
 setClauses.push('age = ?');
 values.push(updates.age);
 }
 
 values.push(id);
 
 const query = `UPDATE users SET ${setClauses.join(', ')} WHERE id = ?`;
 
 try {
 await client.execute(query, values, { prepare: true });
 } catch (error) {
 console.error('Update error:', error);
 throw error;
 }
}

async function deleteUser(id) {
 const query = 'DELETE FROM users WHERE id = ?';
 
 try {
 await client.execute(query, [id], { prepare: true });
 } catch (error) {
 console.error('Delete error:', error);
 throw error;
 }
}

async function showClusterInfo() {
 const hosts = client.hosts.values();
 for (const host of hosts) {
 console.log(host)
 }
}

async function runCRUDTests() {
 try {
 
 await createKeyspaceAndTable();
 await showClusterInfo();
 
 const userId1 = await createUser('John Doe', 'john@example.com', 30);
 const userId2 = await createUser('Jane Smith', 'jane@example.com', 25);
 const userId3 = await createUser('Bob Johnson', 'bob@example.com', 35);
 
 await readUser(userId1);
 await readAllUsers();
 
 await updateUser(userId1, { email: 'john.doe@newmail.com', age: 31 });
 await readUser(userId1);
 
 await deleteUser(userId3);
 await readAllUsers();
 
 const batchQueries = [
 {
 query: 'INSERT INTO users (id, name, email, age, created_at) VALUES (?, ?, ?, ?, ?)',
 params: [cassandra.types.Uuid.random(), 'Alice Brown', 'alice@example.com', 28, new Date()]
 },
 {
 query: 'INSERT INTO users (id, name, email, age, created_at) VALUES (?, ?, ?, ?, ?)',
 params: [cassandra.types.Uuid.random(), 'Charlie Davis', 'charlie@example.com', 32, new Date()]
 }
 ];
 
 await client.batch(batchQueries, { prepare: true });
 await readAllUsers();
 
 } catch (error) {
 console.error('Test error:', error);
 } finally {
 await client.shutdown();
 }
}

setTimeout(() =&gt; {
 runCRUDTests();
}, 30000);
 </div></div>

삽질하는 멍개씨

안녕하세요 멍개입니다. 지난 시간에 카산드라를 다뤄보았습니다. 이번 시간은 카산드라와 완벽하게 호환되는 scylladb를 다뤄보겠습니다. scylladb는 카산드라와 완벽하게 호환되기 때문에 다음 글을 먼저 읽고오는것을 추천드립니다. https://blog.naver.com/pjt3591oo/223972257259 ● 카산드라와 scylladb 비교 scylladb는 카산드라와 완벽한 호환이 되기 때문에 비슷한 형태로 동작하지만 미묘하게 다른 부분이 존재합니다. 하지만 동작 메커니즘 자체는 동일합니다. · 언어적 차이 scylladb와 카산드라의 가장 차이점은 작성된 언어입니다. 카산드라는 Java 기반으로 동작을 합니다. 하지만 scylladb는 c++로 작성되어 있으며, 작성된 언어.......

[scylladb] 카산드라와 완벽 호환되는 NoSQL 데이터베이스 scylladb

댓글