]> git.openstreetmap.org Git - nominatim.git/blob - nominatim/tools/replication.py
864051689b76394226e5148dae8b5caa8929f9f0
[nominatim.git] / nominatim / tools / replication.py
1 """
2 Functions for updating a database from a replication source.
3 """
4 import datetime
5 import logging
6
7 from osmium.replication.server import ReplicationServer
8
9 from ..db import status
10
11 LOG = logging.getLogger()
12
13 def init_replication(conn, base_url):
14     """ Set up replication for the server at the given base URL.
15     """
16     LOG.info("Using replication source: %s", base_url)
17     date = status.compute_database_date(conn)
18
19     # margin of error to make sure we get all data
20     date -= datetime.timedelta(hours=3)
21
22     repl = ReplicationServer(base_url)
23
24     seq = repl.timestamp_to_sequence(date)
25
26     if seq is None:
27         LOG.fatal("Cannot reach the configured replication service '%s'.\n"
28                   "Does the URL point to a directory containing OSM update data?",
29                   base_url)
30         raise RuntimeError("Failed to reach replication service")
31
32     status.set_status(conn, date=date, seq=seq)
33
34     LOG.warning("Updates intialised at sequence %s (%s)", seq, date)