在map_blocks调用中,避免对对象进行序列化操作。可以将对象转换为可以序列化的数据结构,如元组或字典。
以下是示例代码:
class Person: def init(self, name, age): self.name = name self.age = age
person = Person('John', 25) person_dict = {'name': person.name, 'age': person.age}
dask_array.map_blocks(my_function, person_dict)