Как сделать перенос портов при использовании карты трансляции адресов с cassandra?

Question

Я пытаюсь подключиться к кластеру scylladb при компоновке с использованием карты трансляции адресов.

Я могу заставить код работать, только если я жестко закодирую порт при создании экземпляра Cluster:

from cassandra.cluster import Cluster
from cassandra.policies import AddressTranslator
from cassandra.auth import PlainTextAuthProvider

################################################################################
# our variables

address_map = {
    "10.0.24.69:9042": "sl-eu-lon-2-portal.3.dblayer.com:15227",
    "10.0.24.71:9042": "sl-eu-lon-2-portal.2.dblayer.com:15229",
    "10.0.24.70:9042": "sl-eu-lon-2-portal.1.dblayer.com:15228"
}

username = 'scylla'
password = 'changeme'

port = 15227

################################################################################

Далее класс для перевода адресов:

class ComposeAddressTranslator(AddressTranslator):

    def set_map(self, address_map):
        # strip ports from both source and destination as the cassandra python
        # client doesn't appear to support ports translation
        self.address_map = {key.split(':')[0]: value.split(':')[0] for (key, value) in address_map.items()}

    def contact_points(self):
        return [value.split(':')[0] for (key, value) in address_map.items()]

    def translate(self, addr):

        # print some debug output
        print('in translate(self, addr) method', type(addr), addr)

        trans_addr = self.address_map[addr]
        return trans_addr

Теперь давайте подключимся:

compose_translator = ComposeAddressTranslator()
compose_translator.set_map(address_map)

auth_provider = PlainTextAuthProvider(
                            username=username, 
                            password=password
                            )

# if the port parameter value is removed from below, we are unable 
# to establish a connection

cluster = Cluster(
            contact_points = compose_translator.contact_points(),
            address_translator = compose_translator,
            auth_provider = auth_provider,
            cql_version = '3.2.1',
            protocol_version = 2,
            port = port
            )

session = cluster.connect()
session.execute("USE my_keyspace;")
session.shutdown()

Похоже, что библиотека Python Cassandra не поддерживает перевод портов с помощью метода translate? Ниже вы можете увидеть в моем отладочном выводе, что addr, переданный в метод translate, является строковым значением IP-адреса без порта:

in translate(self, addr) method <class 'str'> 10.0.24.69
in translate(self, addr) method <class 'str'> 10.0.24.71

Моя среда:

$ pip freeze | grep cassandra
cassandra-driver==3.10

$ pip freeze | grep cassandra
cassandra-driver==3.10

Answer 1

Другие драйверы Cassandra, такие как драйвер узла, поддерживают трансляцию порта. Документация переводчика nodejs:

MyAddressTranslator.prototype.translate = function (address, port, callback) {
   // Your custom translation logic.
}; 

Выше вы можете видеть, что переводчик получает как IP-адрес, так и порт.

Однако я не верю, что текущий драйвер Python Cassandra поддерживает трансляцию адресов портов:

translate(addr)

Принимает IP-адрес узла и возвращает переведенный адрес, который будет использоваться для подключения к этому узлу.

Здесь вы можете видеть, что переводчик получает только IP-адрес.