nominatim/db/status.py

   1 """
   2 Access and helper functions for the status and status log table.
   3 """
   4 import datetime as dt
   5 import logging
   6 import re
   7
   8 from ..tools.exec_utils import get_url
   9 from ..errors import UsageError
  10
  11 LOG = logging.getLogger()
  12
  13 def compute_database_date(conn):
  14     """ Determine the date of the database from the newest object in the
  15         data base.
  16     """
  17     # First, find the node with the highest ID in the database
  18     with conn.cursor() as cur:
  19         osmid = cur.scalar("SELECT max(osm_id) FROM place WHERE osm_type='N'")
  20
  21         if osmid is None:
  22             LOG.fatal("No data found in the database.")
  23             raise UsageError("No data found in the database.")
  24
  25     LOG.info("Using node id %d for timestamp lookup", osmid)
  26     # Get the node from the API to find the timestamp when it was created.
  27     node_url = 'https://www.openstreetmap.org/api/0.6/node/{}/1'.format(osmid)
  28     data = get_url(node_url)
  29
  30     match = re.search(r'timestamp="((\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2}):(\d{2}))Z"', data)
  31
  32     if match is None:
  33         LOG.fatal("The node data downloaded from the API does not contain valid data.\n"
  34                   "URL used: %s", node_url)
  35         raise UsageError("Bad API data.")
  36
  37     LOG.debug("Found timestamp %s", match[1])
  38
  39     return dt.datetime.fromisoformat(match[1]).replace(tzinfo=dt.timezone.utc)
  40
  41
  42 def set_status(conn, date, seq=None, indexed=True):
  43     """ Replace the current status with the given status.
  44     """
  45     assert date.tzinfo == dt.timezone.utc
  46     with conn.cursor() as cur:
  47         cur.execute("TRUNCATE TABLE import_status")
  48         cur.execute("""INSERT INTO import_status (lastimportdate, sequence_id, indexed)
  49                        VALUES (%s, %s, %s)""", (date, seq, indexed))
  50
  51     conn.commit()
  52
  53
  54 def get_status(conn):
  55     """ Return the current status as a triple of (date, sequence, indexed).
  56         If status has not been set up yet, a triple of None is returned.
  57     """
  58     with conn.cursor() as cur:
  59         cur.execute("SELECT * FROM import_status LIMIT 1")
  60         if cur.rowcount < 1:
  61             return None, None, None
  62
  63         row = cur.fetchone()
  64         return row['lastimportdate'], row['sequence_id'], row['indexed']
  65
  66
  67 def set_indexed(conn, state):
  68     """ Set the indexed flag in the status table to the given state.
  69     """
  70     with conn.cursor() as cur:
  71         cur.execute("UPDATE import_status SET indexed = %s", (state, ))
  72     conn.commit()
  73
  74
  75 def log_status(conn, start, event, batchsize=None):
  76     """ Write a new status line to the `import_osmosis_log` table.
  77     """
  78     with conn.cursor() as cur:
  79         cur.execute("""INSERT INTO import_osmosis_log
  80                        (batchend, batchseq, batchsize, starttime, endtime, event)
  81                        SELECT lastimportdate, sequence_id, %s, %s, now(), %s FROM import_status""",
  82                     (batchsize, start, event))