Discussion :

[skokaina]

Bonjour,
j'essaye tant bien que mal de deserialiser une instance d'object (pattern singleton) à l'aide de pickle.
le probleme est le suivant :
Si je serialize puis deserialize mon instance dans un meme script py, tout se passe bien, cependant, si je fais la serialization et la deserialization a l'aide de deux scripts distincts.. je ne recupere pas l'instance creer lors de la serialization.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
#Object a pickler/depickler
class Workers:  
    #Singleton
    instance = None
 
    class __Impl:
 
        def __init__(self):
            self.attribut = "test"
 
    def __init__(self):
 
        if not Workers.instance:
            Workers.instance = Workers.__Impl()  
 
    def __getattr__(self, attr):
        """ Delegate access to implementation """
        return getattr(self.instance, attr)
 
    def __setattr__(self, attr, value):
        """ Delegate access to implementation """
        return setattr(self.instance, attr, value)

Dans le code suivant, on retrouve bien l'instance apres deserialization (stdout)

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
 
#test.py
import pickle
Serial = Workers()
fd = open("worker.xxx", 'w')
pickle.dump(Serial, fd, pickle.HIGHEST_PROTOCOL)
fd.close()
 
fd = open("worker.xxx", "r")
Deserial = pickle.load(fd)
fd.close()
print Deserial
>> stdout :: <Workers.Workers instance at 0x01E88800>

Alors que si je fais ca en deux temps (lancer test1.py puis test2.py), je recupere None (stdout) :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 
#test1.py
import pickle
Serial = Workers()
fd = open("worker.xxx", 'w')
pickle.dump(Serial, fd, pickle.HIGHEST_PROTOCOL)
fd.close()
 
#test2.py
import pickle
fd = open("worker.xxx", "r")
deserial = pickle.load(fd)
fd.close()
print deserial
>> stdout :: None

Par ailleurs, si j'essaye d'acceder a "attribut", l'exception AttibuteError de declanhe :

AttributeError: 'NoneType' object has no attribute 'attribut'

Quelqu'un aurait une idee d'ou peu venir le probleme?...plz

[pacificator]

Bonjour,

Ta classe Worker est-elle bien importée dans ton script test2.py?

[skokaina]

Bonjour,

Ta classe Worker est-elle bien importée dans ton script test2.py?
__________________
"Etre conscient de la difficulté permet de l'éviter.."
Lao-Tseu.

Heuuu, maybe un manque d'experience... mais je ne vois pas pourquoi je devrais importer Workers dans test2.py ...! (Serait-ce histoire de "caster" l'object deserialisé ???)
Sinon il est en effet bien importé dans autant test.py que test1.py.

[pacificator]

Effectivement, la serialisation ne conserve pas la définition de ta classe, tu es donc obligé de l'importer pour la deserialiser.

Extrait de la doc:

Similarly, when class instances are pickled, their class's code and data are not pickled along with them. Only the instance data are pickled.

Et comme tu utilises des attributs de classe, je ne sais pas si cela va fonctionner ..

[skokaina]

:\ j'ai importé ma classe dans test2.py mais :\ rien n'a changé...
par contre, j'arrive toujours pas a comprendre pourquoi tout marche bien si on realise ca dans un meme fichier py versus dans deux distincts (serialization//deserialization)... dure dure !!!

[Guigui_]

essaie avec le nouveau modèle de classe (enfin qui date maintenant )
=>

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
class Workers(object): 
   ...

[skokaina]

Chui en python 2.4 (ca compte ??)...
je viens de tenter le coup (class Workers(object) mais meme resultat :\

Sinon, le fond du probleme, c'est que j'ai mon appli. qui à travers ma classe Workers demarre plusieurs Threads.
En parallele mon appli. demarre un autre thread (qui lui meme lance un subprocess grace a os.system(python.exe any.py) dans sa methode 'run')

Ensuite, pendant l'execution de any.py, je cherche (dans any.py) a acceder à l'un des threads lancé par mon appli. en lui passant deux objets dans une queue...

=> Problème, et comme illustré à travers mes precedents posts, je n'arrive pas a recuperer l'instance Workers via deserialization (ca doit surement etre une mauvaise methode...)

!!! et le fait (possible solution) de lancer mes threads a travers any.py et non pas l'appli. principale, ne marche pas :\ en effet, l'__init__ pour chaque tache est lancé mais le start() n'est pas invoqué... et la aussi mistère :\ (enfin je soupçonne une histoire de priorité ou tout simplement le fait que any.py soit lancé dans un subprocess ne permet pas de faire des calls vers les start() de chaque Thread ou tout simplement y ont jamais la main...

++ S'il y a un moyen de recuperer l'instance de Workers grace à son adresse en memoire ... une doc m'interesserait bien...

Enfin un casse-tete et un conseil serait plus que bienvenue...

[Guigui_]

Ca ne viendrait pas de la définition de classe Worker ?
sans les fonctions __getattr__(self, attr) et __setattr__(self, attr, value), y'a pas de souci