Python clickhouse_driver through ssh connection error

Question

struggling for a week already with my issue, hope you'll be able to explain to me what is wrong here.

I'm trying to connect Clickhouse DB I have on the remote server, which is on the absolutely default settings. So I'm connecting to a remote server and creating a tunnel on my machine.

import sshtunnel as sshtunnel
from clickhouse_driver import connect

server = sshtunnel.SSHTunnelForwarder(
    ('host', 22),
    ssh_username='username',
    ssh_pkey="username.openssh",
    ssh_private_key_password="password",
    remote_bind_address=('localhost', 8123),
    local_bind_address=('localhost', 555)
)

server.start()
conn = connect(host='localhost', port=555, database='ertb')
cursor = conn.cursor()
cursor.execute('SHOW TABLES')
cursor.fetchall()
server.stop()

and I receive this error

Traceback (most recent call last):
  File "C:/Users/user/PycharmProjects/alerts/ssh_coonection.py", line 42, in <module>
    cursor.execute('SHOW TABLES')
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\dbapi\cursor.py", line 102, in execute
    **execute_kwargs
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\client.py", line 205, in execute
    self.connection.force_connect()
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\connection.py", line 180, in force_connect
    self.connect()
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\connection.py", line 256, in connect
    return self._init_connection(host, port)
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\connection.py", line 237, in _init_connection
    self.send_hello()
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\connection.py", line 325, in send_hello
    write_binary_str(self.user, self.fout)
  File "C:\Users\user\PycharmProjects\alerts\venv\lib\site-packages\clickhouse_driver\writer.py", line 19, in write_binary_str
    text = text.encode('utf-8')
AttributeError: 'NoneType' object has no attribute 'encode'

I really tried to understand from where this NoneType object appears, but a bit stuck in code.

but mymarilyn/clickhouse-driver uses tcp protocol on port 9000 not http(8123) — Denny Crane
– Denny Crane, Commented Jun 30, 2020 at 18:50
Thank you, I've used 9000 port and clickhouse_driver Client so everything started to work — Mike Palii
– Mike Palii, Commented Jul 1, 2020 at 7:18

vladimir · Accepted Answer · 2020-07-01 07:19:56Z

There are two issues:

is not passed user and password that leads to the error 'NoneType' object has no attribute 'encode'
used the wrong port to access to CH (clickhouse-driver is designed to communicate with ClickHouse server over native protocol (TCP) that by default use port 9000 for non-secure communication (see Issue connecting to Dockerized Clickhouse Server with Python driver for details))

import sshtunnel as sshtunnel
from clickhouse_driver import connect

with sshtunnel.SSHTunnelForwarder(
    ('localhost', 22),
    ssh_username="root",
    ssh_password="root",
    remote_bind_address=('localhost', 9000)) as server:

    local_port = server.local_bind_port
    print(local_port)

    conn = connect(f'clickhouse://default:@localhost:{local_port}/ertb')
    #conn = connect(host='localhost', port=local_port, database='ertb', user='default', password='')

    cursor = conn.cursor()
    cursor.execute('SHOW TABLES')
    print(cursor.fetchall())

Collectives™ on Stack Overflow

Python clickhouse_driver through ssh connection error

1 Answer 1

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related