Hazelcast和python没有适合类型-120的反序列化程序

Question

您好，我猜客户端和成员配置有问题，我应该使用哪个配置，正如您所看到的，当我调用get_data时，它返回时没有问题，但当我尝试使用谓词sql时，它会给我错误消息“hazelcast.errors.HazelcastSerializationError:服务器异常：com.hazelcast.nio.serialization.HazelcastSerializationException:没有适合类型-120的反序列化程序。此异常可能是由成员之间或客户端与成员之间的序列化配置差异造成的。”

@app.route('/insert_data/<database_name>/<collection_name>', methods=['POST'])
def insert_data(database_name, collection_name):
    client = hazelcast.HazelcastClient(cluster_members=[
        url
    ])
    dbname_map = client.get_map(f"{database_name}-{collection_name}").blocking()

    if request.json:
        received_json_data = request.json
        received_id = received_json_data["_id"]
        del received_json_data["_id"]
        dbname_map.put(received_id, received_json_data)
        client.shutdown()
        return jsonify()

    else:
        client.shutdown()
        abort(400)

@app.route('/get_data/<database_name>/<collection_name>', methods=['GET'])
def get_all_data(database_name, collection_name):
    client = hazelcast.HazelcastClient(cluster_members=[
        url
    ])
    dbname_map = client.get_map(f"{database_name}-{collection_name}").blocking()
    entry_set = dbname_map.entry_set()
    output = dict()
    datas = []
    for key, value in entry_set:
        value['_id'] = key
        output = value
        datas.append(output)

    client.shutdown()
    return jsonify({"Result":datas})

@bp.route('/get_query/<database_name>/<collection_name>/<name>', methods=['GET'])
def get_query_result(database_name, collection_name,name):
     client = hazelcast.HazelcastClient(cluster_members=[
        url
    ])
    predicate_map = client.get_map(f"{database_name}-{collection_name}").blocking()
    predicate = and_(sql(f"name like {name}%"))
    entry_set = predicate_map.values(predicate)
    #entry_set = predicate_map.entry_set(predicate)

    send_all_data = ""
    for x in entry_set:
        send_all_data += x.to_string()
        send_all_data += "\n"
        print(send_all_data)
    # print("Retrieved %s values whose age is less than 30." % len(result))
    # print("Entry is", result[0].to_string())
    # value=predicate_map.get(70)
    # print(value)
    return jsonify()

我试图改变黑泽尔卡斯特。xml根据hazelcast的完整示例。xml，但我不能在更改后启动hazelcast，我真的必须使用序列化吗？hazelcast版本：4.1 python:3.9

Answer 1

这很可能是因为您正在将类型字典的条目放入映射，而映射由pickle序列化，因为您没有为此指定序列化程序，而客户端不知道如何正确处理，所以它会退回到默认序列化程序。然而，由于pickle序列化是特定于Python的，服务器无法对其进行反序列化并引发这样的异常。

有可能的解决方案，请参阅https://hazelcast.readthedocs.io/en/stable/serialization.html第二章了解详情。

我认为最适合您的用例的解决方案是可移植序列化，它不需要在服务器端更改配置或代码。请参阅https://hazelcast.readthedocs.io/en/stable/serialization.html#portable-serialization

顺便说一句，客户端对象非常重，所以你不应该像这样按需创建它们。您可以在应用程序中一次性构造它，并在endpoint或业务逻辑代码中自由共享和使用它，因为它是线程安全的。这同样适用于从客户端获得的映射代理。它也可以重复使用。