script/lib/iri_tweet/tweet_twitter_user.py
changeset 286 6ac68295defe
parent 255 500cd0405c7a
child 289 a5eff8f2b81d
equal deleted inserted replaced
285:f1bc9fe452d5 286:6ac68295defe
    52     
    52     
    53     (options, args) = get_options()
    53     (options, args) = get_options()
    54     
    54     
    55     set_logging(options)
    55     set_logging(options)
    56         
    56         
    57     logger.debug("OPTIONS : " + repr(options)) #@UndefinedVariable
    57     get_logger().debug("OPTIONS : " + repr(options)) #@UndefinedVariable
    58 
    58 
    59     if not options.message or len(options.message) == 0:
    59     if not options.message or len(options.message) == 0:
    60         sys.exit()
    60         sys.exit()
    61 
    61 
    62     conn_str = options.database.strip()
    62     conn_str = options.database.strip()
   110 
   110 
   111             for user in query_res:
   111             for user in query_res:
   112                 screen_name = user.screen_name
   112                 screen_name = user.screen_name
   113                 
   113                 
   114                 message = u"@%s: %s" % (screen_name, base_message)
   114                 message = u"@%s: %s" % (screen_name, base_message)
   115                 get_logger.debug("new status : " + message) #@UndefinedVariable
   115                 get_logger().debug("new status : " + message) #@UndefinedVariable
   116                 if not options.simulate:
   116                 if not options.simulate:
   117                     t.statuses.update(status=message)
   117                     t.statuses.update(status=message)
   118                     user_message = UserMessage(user_id=user.id, message_id=message_obj.id)
   118                     user_message = UserMessage(user_id=user.id, message_id=message_obj.id)
   119                     session.add(user_message)
   119                     session.add(user_message)
   120                     session.flush()
   120                     session.flush()