···

       
50
       
50
       
 
       
                dict(uri=post_uri, ts=ts)

     

       
51
       
51
       
 
       
            )

     

       
52
       
52
       
 
       


     

       
53
       
53
       
-
       
    def delete_old_posts(self):

     

       
54
       
54
       
-
       
        self.db_cnx.execute(

     

       
55
       
55
       
-
       
            "delete from posts where create_ts < unixepoch('-24 hours')"

     

       
56
       
56
       
-
       
        )

     

       
57
       
57
       
-
       


     

       
58
       
53
       
 
       
    def commit_changes(self):

     

       
59
       
54
       
 
       
        self.logger.debug('committing changes')

     

       
60
       
60
       
-
       
        self.delete_old_posts()

     

       
61
       
55
       
 
       
        self.transaction_commit(self.db_cnx)

     

       
62
       
56
       
 
       
        self.wal_checkpoint(self.db_cnx, 'RESTART')

     

       
63
       
57