FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
cassandra-python-driver/example_core.py at trunk · apache/cassandra-python-driver · GitHub
Uh oh!
There was an error while loading.
Please reload this page
.
apache
/
cassandra-python-driver
Public
Notifications
You must be signed in to change notification settings
Fork
586
Star
1.4k
Code
Pull requests
14
Actions
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Security and quality
Insights
Expand file tree
Breadcrumbs
cassandra-python-driver
/
example_core.py
Copy path
More file actions
More file actions
Latest commit
History
History
History
88 lines (70 loc) · 2.59 KB
Breadcrumbs
cassandra-python-driver
/
example_core.py
Copy path
File metadata and controls
88 lines (70 loc) · 2.59 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
#!/usr/bin/env python
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
import
logging
log
=
logging
.
getLogger
()
log
.
setLevel
(
'DEBUG'
)
handler
=
logging
.
StreamHandler
()
handler
.
setFormatter
(
logging
.
Formatter
(
"%(asctime)s [%(levelname)s] %(name)s: %(message)s"
))
log
.
addHandler
(
handler
)
from
cassandra
import
ConsistencyLevel
from
cassandra
.
cluster
import
Cluster
from
cassandra
.
query
import
SimpleStatement
KEYSPACE
=
"testkeyspace"
def
main
():
cluster
=
Cluster
([
'127.0.0.1'
])
session
=
cluster
.
connect
()
log
.
info
(
"creating keyspace..."
)
session
.
execute
(
"""
CREATE KEYSPACE IF NOT EXISTS %s
WITH replication = { 'class': 'SimpleStrategy', 'replication_factor': '2' }
"""
%
KEYSPACE
)
log
.
info
(
"setting keyspace..."
)
session
.
set_keyspace
(
KEYSPACE
)
log
.
info
(
"creating table..."
)
session
.
execute
(
"""
CREATE TABLE IF NOT EXISTS mytable (
thekey text,
col1 text,
col2 text,
PRIMARY KEY (thekey, col1)
)
"""
)
query
=
SimpleStatement
(
"""
INSERT INTO mytable (thekey, col1, col2)
VALUES (%(key)s, %(a)s, %(b)s)
"""
,
consistency_level
=
ConsistencyLevel
.
ONE
)
prepared
=
session
.
prepare
(
"""
INSERT INTO mytable (thekey, col1, col2)
VALUES (?, ?, ?)
"""
)
for
i
in
range
(
10
):
log
.
info
(
"inserting row %d"
%
i
)
session
.
execute
(
query
,
dict
(
key
=
"key%d"
%
i
,
a
=
'a'
,
b
=
'b'
))
session
.
execute
(
prepared
, (
"key%d"
%
i
,
'b'
,
'b'
))
future
=
session
.
execute_async
(
"SELECT * FROM mytable"
)
log
.
info
(
"key
\t
col1
\t
col2"
)
log
.
info
(
"---
\t
----
\t
----"
)
try
:
rows
=
future
.
result
()
except
Exception
:
log
.
exception
(
"Error reading rows:"
)
return
for
row
in
rows
:
log
.
info
(
'
\t
'
.
join
(
row
))
session
.
execute
(
"DROP KEYSPACE "
+
KEYSPACE
)
if
__name__
==
"__main__"
:
main
()
Back
|
FazBrowse Home
|
New Git URL