09_DEMO


In [1]:
import pulltoview
pulltoview.keep_pulling_to_view()


---------------------------------------------------------------------------
OperationalError                          Traceback (most recent call last)
<ipython-input-1-36d7ca396410> in <module>()
      1 import pulltoview
----> 2 pulltoview.keep_pulling_to_view()

/Users/markhallett/github/MeDaReDa/demos/demo1/pulltoview.pyc in keep_pulling_to_view()
    101 def keep_pulling_to_view():
    102     while True:
--> 103         pull_to_view()
    104 
    105 if __name__ == '__main__':

/Users/markhallett/github/MeDaReDa/demos/demo1/pulltoview.pyc in pull_to_view()
     46 def pull_to_view():
     47     max_pulled_data_row = get_max_pulled_data_row()
---> 48     rows_to_pull = get_rows_to_pull(max_pulled_data_row)
     49     if not rows_to_pull:
     50         #print 'no data to pull'

/Users/markhallett/github/MeDaReDa/demos/demo1/pulltoview.pyc in get_rows_to_pull(max_processed_data_row)
     25 
     26 def get_rows_to_pull(max_processed_data_row):
---> 27     conn = get_conn()
     28     cur = conn.cursor()
     29     sql = "SELECT * FROM dPrice where dPriceId > %s" %max_processed_data_row

/Users/markhallett/github/MeDaReDa/demos/demo1/pulltoview.pyc in get_conn()
      5 
      6 def get_conn():
----> 7     return medareda_lib.get_conn()
      8 
      9 def get_max_pulled_data_row():

/Users/markhallett/github/MeDaReDa/demos/demo1/medareda_lib.pyc in get_conn()
     24     (host, dbname, user, password) = get_ini_data ('worker',('host','dbname','user','password'))
     25     conn_string = "host='%s' dbname='%s' user='%s' password='%s'" %(host, dbname, user, password)
---> 26     conn = psycopg2.connect(conn_string)
     27     return conn
     28 

/Library/Python/2.7/site-packages/psycopg2/__init__.pyc in connect(dsn, database, user, password, host, port, connection_factory, cursor_factory, async, **kwargs)
    162                 for (k, v) in items])
    163 
--> 164     conn = _connect(dsn, connection_factory=connection_factory, async=async)
    165     if cursor_factory is not None:
    166         conn.cursor_factory = cursor_factory

OperationalError: could not connect to server: Operation timed out
	Is the server running on host "5.79.26.24" and accepting
	TCP/IP connections on port 5432?

In [ ]: