Path: csiph.com!v102.xanadu-bbs.net!xanadu-bbs.net!goblin3!goblin2!goblin.stu.neva.ru!newsfeed.xs4all.nl!newsfeed1.news.xs4all.nl!xs4all!post.news.xs4all.nl!not-for-mail Return-Path: X-Original-To: python-list@python.org Delivered-To: python-list@mail.python.org X-Spam-Status: OK 0.001 X-Spam-Evidence: '*H*': 1.00; '*S*': 0.00; 'subject:not': 0.03; '"""': 0.07; 'filename:fname piece:py': 0.07; 'modify': 0.07; 'none:': 0.07; 'skip:" 60': 0.07; 'executed': 0.09; 'def': 0.12; 'creates': 0.14; 'thread': 0.14; 'changes': 0.15; '%r"': 0.16; "'.lock')": 0.16; '33,': 0.16; 'subject:Problems': 0.16; 'subject:object': 0.16; 'subject:threads': 0.16; 'thread,': 0.16; 'threads.': 0.16; 'url:file': 0.16; 'do.': 0.18; 'trying': 0.19; 'commit': 0.19; 'skip:f 30': 0.19; 'seems': 0.21; 'example': 0.22; 'manual': 0.22; 'separate': 0.22; 'skip:\xa0 20': 0.24; 'skip:" 30': 0.26; 'second': 0.26; 'skip:" 20': 0.27; 'raise': 0.29; 'skip:& 60': 0.30; 'message-id:@mail.gmail.com': 0.30; 'skip:& 70': 0.31; 'file': 0.32; 'class': 0.32; 'this.': 0.32; 'run': 0.32; 'open': 0.33; '(most': 0.33; 'skip:& 30': 0.33; 'skip:_ 10': 0.34; 'subject:from': 0.34; 'subject:with': 0.35; 'connection': 0.35; 'transaction': 0.35; 'objects': 0.35; 'but': 0.35; 'received:google.com': 0.35; 'there': 0.35; 'skip:" 50': 0.36; 'should': 0.36; 'error.': 0.37; 'sometimes': 0.38; 'skip:& 10': 0.38; '8bit%:4': 0.38; 'to:addr:python-list': 0.38; 'recent': 0.39; 'skip:& 20': 0.39; "couldn't": 0.39; 'subject:can': 0.39; '\xa0\xa0\xa0': 0.39; 'to:addr:python.org': 0.39; '8bit%:6': 0.40; 'how': 0.40; 'tell': 0.60; 'new': 0.61; 'skip:* 10': 0.61; 'here:': 0.62; 'save': 0.62; 'different': 0.65; 'self.run()': 0.84; '\xa0\xa0\xa0\xa0\xa0\xa0\xa0\xa0\xa0\xa0\xa0': 0.84 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=hHqa6bBDbj2AMxsr2MK4YdOz3THIJbhg3gWVekmPkws=; b=DBqGkMZJOmoTslhiK9+vXCAZYGMdMLw7TwiE7PqSGH0Jy6T8mTO3TDc1rA61ZCTPsA 1HDtVcyKh4TwvkURtg06a6fqpETvkXJoMUfs3Twhz7T9EflaAOsQQYgz3kZC2J+8/0Gb HKIMCUaLmYGA+AQw77J3sHcbYmNrvUjsuCahHoUvaYJq08XAK4sWBy+7IT/gmG3kfj13 Z/UUZ2N0FvlzDKpHYM/WO99LolPtJatuYBVajcU0Wf1yiBvlPRXoi2uBWOSobA2zvhcS wmsvrbKeN1Qa+ftsFlYdkVH5Cr9yDIanO2NMm/UGI6a7grQqeKpuGwjbgel98x5b0bh5 Cg3w== MIME-Version: 1.0 X-Received: by 10.152.22.136 with SMTP id d8mr85017laf.66.1398805527123; Tue, 29 Apr 2014 14:05:27 -0700 (PDT) Date: Tue, 29 Apr 2014 21:05:24 +0000 Subject: Problems with ZODB, I can not persist and object accessed from 2 threads From: =?ISO-8859-1?Q?Ariel_Arga=F1araz?= To: python-list@python.org Content-Type: multipart/mixed; boundary=089e0158b6e48deefc04f834cac1 X-Mailman-Approved-At: Wed, 30 Apr 2014 00:54:52 +0200 X-BeenThere: python-list@python.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: General discussion list for the Python programming language List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Newsgroups: comp.lang.python Message-ID: Lines: 194 NNTP-Posting-Host: 2001:888:2000:d::a6 X-Trace: 1398812094 news.xs4all.nl 2837 [2001:888:2000:d::a6]:37826 X-Complaints-To: abuse@xs4all.nl Xref: csiph.com comp.lang.python:70737 --089e0158b6e48deefc04f834cac1 Content-Type: multipart/alternative; boundary=089e0158b6e48deef804f834cabf --089e0158b6e48deef804f834cabf Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hello, I am sorry I am stuck in this. And I need some help I want to persist an Object with ZODB, the object can be accessed from 2 different threads. The ZODB manual says: A multi-threaded program should open a separate Connection instance for each thread. Different threads can then modify objects and commit their modifications independently. But there isn't an example of how to create a connection for each thread. Can someone tell me how to connect to the same DB from 2 threads?? I attached an example of what I am trying to do. And I get this error. Traceback (most recent call last): File "/usr/lib/python2.7/threading.py", line 810, in __bootstrap_inner self.run() File "/usr/lib/python2.7/threading.py", line 763, in run self.__target(*self.__args, **self.__kwargs) File "main.py", line 33, in thread_1 storage =3D FileStorage("/tmp/asdasd.fs") File "/usr/lib/python2.7/site-packages/ZODB/FileStorage/FileStorage.py", line 164, in *_init_* self._lock_file =3D LockFile(file_name + '.lock') File "/usr/lib/python2.7/site-packages/zc/lockfile/__init__.py", line 84, in *_init_* _lock_file(fp) File "/usr/lib/python2.7/site-packages/zc/lockfile/__init__.py", line 59, in _lock_file raise LockError("Couldn't lock %r" % file.name) LockError: Couldn't lock '/tmp/asdasd.fs.lock' IF I don't connect in the "thread_1" class I can change things but sometimes the changes from the main thread are not commited. When I debug, I can see that when a change is made from the Second thread, the "transaction_manager" creates a new Transaction here: #manager.py def get(self): """ See ITransactionManager. """ if self._txn is None: self._txn =3D Transaction(self._synchs, self) return self._txn When it happens that commit Seems to be executed succesfully but it doest save the changes to the DB. --=20 Ariel Arga=F1araz --089e0158b6e48deef804f834cabf Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hello, I am sorry I am stuck in this. An= d I need some help

I want to persist an Object with ZODB, the object= can be accessed from 2=A0 different threads. The ZODB manual says:

= A multi-threaded program should open a=20 separate Connection instance for each thread. Different threads can then modify objects and commit their modifications independently.

But there isn't an example of how to create a connection for each thread.= =20 Can someone tell me how to connect to the same DB from 2 threads??

I= attached an example of what I am trying to do.

And I get this error= .

Traceback (most recent = call last):
=A0File "/usr/lib/python2.7/threading.py", line 810, in __bootst= rap_inner
=A0 =A0self.run()
=A0File "/usr/lib/python2.7/thread= ing.py", line 763, in run
=A0 =A0self.__target(*self.__args, **sel= f.__kwargs)
=A0File "main.py", line 33, in thread_1
=A0 =A0storage =3D F= ileStorage("/tmp/asdasd.fs")
=A0File "/usr/lib/python2.7= /site-packages/ZODB/FileStorage/FileStorage.py", line 164, in _init= _
=A0 =A0self._lock_file =3D LockFile(file_name + '.lock')
=A0Fi= le "/usr/lib/python2.7/site-packages/zc/lockfile/__init__.py", li= ne 84, in _init_
=A0 =A0_lock_file(fp)
=A0File "/usr/li= b/python2.7/site-packages/zc/lockfile/__init__.py", line 59, in _lock_= file
=A0 =A0raise LockError("Couldn't lock %r" % file.name)
LockError: Couldn't lo= ck '/tmp/asdasd.fs.lock'


IF I don't connect i= n the "thread_1" class I can change things but sometimes the chan= ges from the main thread are not commited.

When I debug, I can see that when a change is made from the Second thread,=20 the "transaction_manager" creates a new Transaction here:

= #manager.py
=A0=A0=A0 def get(self):
=A0=A0=A0=A0=A0=A0=A0 "&quo= t;" See ITransactionManager.
=A0=A0=A0=A0=A0=A0=A0 ""&quo= t;
=A0=A0=A0=A0=A0=A0=A0 if self._txn is None:
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 self._txn =3D Transaction(self._synchs, s= elf)
=A0=A0=A0=A0=A0=A0=A0 return self._txn

When it happens that = commit Seems to be executed succesfully but it doest save the changes to th= e DB.

--
Ariel Arga=F1araz


--089e0158b6e48deef804f834cabf-- --089e0158b6e48deefc04f834cac1 Content-Type: application/x-download; name="main.py" Content-Disposition: attachment; filename="main.py" Content-Transfer-Encoding: base64 X-Attachment-Id: f_huli8q070 ZnJvbSBvYmplY3RzIGltcG9ydCBFbnRlcnByaXNlLCBFbXBsb3llZQoKZnJvbSBaT0RCIGltcG9y dCBEQiwgQ29ubmVjdGlvbgpmcm9tIFpPREIuRmlsZVN0b3JhZ2UgaW1wb3J0IEZpbGVTdG9yYWdl CmltcG9ydCB0cmFuc2FjdGlvbgoKaW1wb3J0IHRocmVhZGluZwppbXBvcnQgdGltZQppbXBvcnQg cmFuZG9tCgoKZGVmIHByaW50X2VudGVycHJpc2UoZW50ZXJwcmlzZSk6CiAgICBwcmludCAiLS0t LS0tLS0tLS0tLS0tLS0tLS0gREFUQSBGUk9NIERCIgogICAgZW50ZXJwcmlzZS5wcmludF9zdGF0 ZSgpCiAgICBwcmludCAiLS0tLS0tLS0tLS0tLS0tLS0tLS0gRU5EIERBVEEgRlJPTSBEQiIKCgpk ZWYgYnVpbGRfZW50ZXJwcmlzZSgpOgogICAgZW50ZXJwcmlzZSA9IEVudGVycHJpc2UoIk1pY3Jv c29mdCIpCiAgICBlbnRlcnByaXNlLmFkZF9lbXBsb3llZShFbXBsb3llZSgiTnVtZXJvMSIsIDEp KQogICAgZW50ZXJwcmlzZS5hZGRfZW1wbG95ZWUoRW1wbG95ZWUoIk51bWVybzIiLCAyKSkKICAg IGVudGVycHJpc2UuYWRkX2VtcGxveWVlKEVtcGxveWVlKCJOdW1lcm8zIiwgMykpCiAgICBlbnRl cnByaXNlLmFkZF9lbXBsb3llZShFbXBsb3llZSgiTnVtZXJvNCIsIDQpKQogICAgZW50ZXJwcmlz ZS5hZGRfZW1wbG95ZWUoRW1wbG95ZWUoIk51bWVybzUiLCA1KSkKCiAgICByZXR1cm4gZW50ZXJw cmlzZQoKCmRlZiB0aHJlYWRfMShlbnRlcnByaXNlLCBlbXBsb3llZXMsIG51bWJlcik6CiAgICBw cmludCAic3RhcnRpbmcgdGhyZWFkIgogICAgI2RiLgogICAgI2Nvbm5lY3Rpb25fID0gQ29ubmVj dGlvbihkYikKICAgIHN0b3JhZ2UgPSBGaWxlU3RvcmFnZSgiL3RtcC9hc2Rhc2QuZnMiKQogICAg ZGIgPSBEQihzdG9yYWdlKQogICAgY29ubmVjdGlvbiA9IGRiLm9wZW4oKQogICAgcm9vdCA9IGNv bm5lY3Rpb24ucm9vdCgpCiAgICBuID0gbnVtYmVyCiAgICBmb3IgZSBpbiBlbXBsb3llZXM6CiAg ICAgICAgcHJpbnQgIm1vZGlmeWluZyBOYW1lIG9uIHRocmVhZCIgIyBFbXBsb3llZSB7MH0iLmZv cm1hdChlKQogICAgICAgIGUuX25hbWUgPSAibmFtZXswfSIuZm9ybWF0KG4pCiAgICAgICAgdHJh bnNhY3Rpb24uY29tbWl0KCkKICAgICAgICB0aW1lLnNsZWVwKHJhbmRvbS5yYW5kb20oKSkKICAg IHByaW50ICJmaW5pc2hpbmcgdGhyZWFkIgoKCmRlZiBtYWluKCk6CiAgICAjIHNldHVwIHRoZSBk YXRhYmFzZQogICAgc3RvcmFnZSA9IEZpbGVTdG9yYWdlKCIvdG1wL2FzZGFzZC5mcyIpCiAgICBk YiA9IERCKHN0b3JhZ2UpCiAgICBjb25uZWN0aW9uID0gZGIub3BlbigpCiAgICByb290ID0gY29u bmVjdGlvbi5yb290KCkKICAgIGlmICJudW1iZXIiIG5vdCBpbiByb290OgogICAgICAgIHJvb3Rb Im51bWJlciJdID0gMAogICAgcm9vdFsibnVtYmVyIl0gKz0gMQogICAgdHJhbnNhY3Rpb24uY29t bWl0KCkKICAgIG51bWJlciA9IHJvb3RbIm51bWJlciJdCiAgICBpZiAiZW50ZXJwcmlzZSIgbm90 IGluIHJvb3Q6CiAgICAgICAgcm9vdFsiZW50ZXJwcmlzZSJdID0gYnVpbGRfZW50ZXJwcmlzZSgp CiAgICAgICAgdHJhbnNhY3Rpb24uY29tbWl0KCkKICAgIGVudGVycHJpc2UgPSByb290WyJlbnRl cnByaXNlIl0KCiAgICBwcmludF9lbnRlcnByaXNlKGVudGVycHJpc2UpCgogICAgZW1wbG95ZWVz ID0gZW50ZXJwcmlzZS5fZW1wbG95ZWVzCiAgICBuZXdfdGhyZWFkID0gdGhyZWFkaW5nLlRocmVh ZCh0YXJnZXQ9dGhyZWFkXzEsIGFyZ3M9W2VudGVycHJpc2UsIGVtcGxveWVlcywKICAgICAgICAg ICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgbnVtYmVyXSkK ICAgIG5ld190aHJlYWQuc3RhcnQoKQogICAgZm9yIGUgaW4gZW1wbG95ZWVzOgogICAgICAgIG5l d19hZ2UgPSByYW5kb20ucmFuZGludCgwLCAxMDApCiAgICAgICAgcHJpbnQgIkNoYW5naW5nIEFH RSB0byBlbXBsb3llZTogezB9IHRvOid7MX0nIi5mb3JtYXQoZSwgbmV3X2FnZSkKICAgICAgICBl Ll9hZ2UgPSBuZXdfYWdlCiAgICAgICAgdHJhbnNhY3Rpb24uY29tbWl0KCkKICAgICAgICB0aW1l LnNsZWVwKHJhbmRvbS5yYW5kb20oKSkKCgppZiBfX25hbWVfXyA9PSAiX19tYWluX18iOgogICAg bWFpbigp --089e0158b6e48deefc04f834cac1 Content-Type: application/x-download; name="objects.py" Content-Disposition: attachment; filename="objects.py" Content-Transfer-Encoding: base64 X-Attachment-Id: f_huli8q181 ZnJvbSBwZXJzaXN0ZW50IGltcG9ydCBQZXJzaXN0ZW50CgoKY2xhc3MgRW1wbG95ZWUoUGVyc2lz dGVudCk6CiAgICAiIiJBbiBlbXBsb3llZSIiIgoKICAgIGRlZiBfX2luaXRfXyhzZWxmLCBuYW1l LCBhZ2UpOgogICAgICAgIHNlbGYuX25hbWUgPSBuYW1lCiAgICAgICAgc2VsZi5fYWdlID0gYWdl CiAgICAgICAgI3NlbGYubG9jayA9IHRocmVhZGluZy5Mb2NrKCkKCiAgICBkZWYgX19zdHJfXyhz ZWxmKToKICAgICAgICByZXR1cm4gIkVtcGxveWVlICd7MH0nIHsxfSB5ZWFycyBvbGQiLmZvcm1h dChzZWxmLl9uYW1lLAogICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAg ICAgICAgICAgIHNlbGYuX2FnZSkKCiAgICBkZWYgcHJpbnRfc3RhdGUoc2VsZik6CiAgICAgICAg cHJpbnQgIioqKiogTkFNRTonezB9Jy1BR0U6J3sxfSciLmZvcm1hdChzZWxmLl9uYW1lLCBzZWxm Ll9hZ2UpCgogICAgIiIiCiAgICBkZWYgX19nZXRzdGF0ZV9fKHNlbGYpOgogICAgICAgIHByaW50 ICItLS0tLS0tLXVzaW5nIEdFVCBzdGF0ZSIKICAgICAgICByZXR1cm4gKHNlbGYubmFtZSwgc2Vs Zi5tYW5hZ2VyLCBzZWxmLmFnZSwgInVuTG9jayIsIHNlbGYuZnJpZW5kcykKCiAgICBkZWYgX19z ZXRzdGF0ZV9fKHNlbGYsIHN0YXRlKToKICAgICAgICBwcmludCAiLS0tLS0tLS11c2luZyBTRVRz dGF0ZS0iCiAgICAgICAgcHJpbnQgInN0YXRlOnt9Ii5mb3JtYXQoc3RhdGUpCiAgICAgICAgcHJp bnQgIi0tLS0tLS0tLSIKICAgICAgICBzZWxmLm5hbWUsIHNlbGYubWFuYWdlciwgc2VsZi5hZ2Us IHNlbGYubG9jaywgc2VsZi5mcmllbmRzID0gc3RhdGUKICAgICAgICBzZWxmLmxvY2sgPSB0aHJl YWRpbmcuTG9jaygpCiAgICAgICAgcHJpbnQgImVuZCBzZXRzdGF0ZSIKICAgICIiIgoKICAgICIi IgogICAgZGVmIHNldF9hZ2Uoc2VsZiwgYWdlKToKICAgICAgICBzZWxmLmxvY2suYWNxdWlyZSgp CiAgICAgICAgc2VsZi5hZ2UgPSBhZ2UKICAgICAgICB0cmFuc2FjdGlvbi5jb21taXQoKQogICAg ICAgIHNlbGYubG9jay5yZWxlYXNlKCkKCiAgICBkZWYgYWRkX2ZyaWVuZChzZWxmLCBmcmllbmQp OgoKICAgICAgICBzZWxmLmZyaWVuZHMuYXBwZW5kKChmcmllbmQsICJhbWlnYWNobyIpKQogICAg ICAgIHNlbGYuX3BfY2hhbmdlZCA9IDEKICAgICAgICBwcmludCBzZWxmLl9wX2NoYW5nZWQKICAg ICIiIgoKCmNsYXNzIEVudGVycHJpc2UoUGVyc2lzdGVudCk6CgogICAgZGVmIF9faW5pdF9fKHNl bGYsIG5hbWUpOgogICAgICAgIHNlbGYuX2VtcGxveWVlcyA9IFtdCiAgICAgICAgc2VsZi5fbmFt ZSA9IG5hbWUKCiAgICBkZWYgX19zdHJfXyhzZWxmKToKICAgICAgICByZXR1cm4gIkVudGVycHJp c2UgJ3swfSciLmZvcm1hdChzZWxmLl9uYW1lKQoKICAgIGRlZiBwcmludF9zdGF0ZShzZWxmKToK ICAgICAgICBwcmludCAiRW50ZXJwcmlzZSBuYW1lOiAnezB9JyAtIENhbnQuIGVtcGxveWVlczp7 MX0iLmZvcm1hdChzZWxmLl9uYW1lLAogICAgICAgICAgICBsZW4oc2VsZi5fZW1wbG95ZWVzKSkK ICAgICAgICBwcmludCAiRW1wbG95ZWVzOiIKICAgICAgICBmb3IgZSBpbiBzZWxmLl9lbXBsb3ll ZXM6CiAgICAgICAgICAgIGUucHJpbnRfc3RhdGUoKQoKICAgIGRlZiBhZGRfZW1wbG95ZWUoc2Vs ZiwgZW1wbG95ZWUpOgogICAgICAgIHNlbGYuX2VtcGxveWVlcy5hcHBlbmQoZW1wbG95ZWUpCiAg ICAgICAgc2VsZi5fcF9jaGFuZ2VkID0gVHJ1ZQoKICAgIGRlZiByZW1vdmVfZW1wbG95ZWUoc2Vs ZiwgZW1wbG95ZWUpOgogICAgICAgIHNlbGYuX2VtcGxveWVlcy5yZW1vdmUoZW1wbG95ZWUpCiAg ICAgICAgc2VsZi5fcF9jaGFuZ2VkID0gVHJ1ZQo= --089e0158b6e48deefc04f834cac1--