tile: send replicate logs to systemd journald

[chef.git] / cookbooks / tile / templates / default / replicate.erb

diff --git a/cookbooks/tile/templates/default/replicate.erb b/cookbooks/tile/templates/default/replicate.erb
index 1b6c61bbc96f588ee5810a9f6e71b9cfce5ffd86..ea0e100cf46e7fe14c423f4f8c3442e5a3208913 100644 (file)
--- a/cookbooks/tile/templates/default/replicate.erb
+++ b/cookbooks/tile/templates/default/replicate.erb
@@ -9,86 +9,95 @@
 
 # Define exit handler
 function onexit {
 
 # Define exit handler
 function onexit {

-    [ -f state-prev.txt ] && mv state-prev.txt state.txt
+    [ -f sequence-prev.txt ] && mv sequence-prev.txt sequence.txt

 }
 
 }
 

-# Send output to the log
-exec > /var/log/tile/replicate.log 2>&1
-

 # Change to the replication state directory
 cd /var/lib/replicate
 
 # Install exit handler
 trap onexit EXIT
 
 # Change to the replication state directory
 cd /var/lib/replicate
 
 # Install exit handler
 trap onexit EXIT
 

-# Read in initial state
-. state.txt
-

 # Loop indefinitely
 while true
 do
     # Work out the name of the next file
 # Loop indefinitely
 while true
 do
     # Work out the name of the next file

-    file="changes-${sequenceNumber}.osm.gz"
+    file="changes-$(cat sequence.txt).osc.gz"

 
 

-    # Save state file so we can rollback if an error occurs
-    cp state.txt state-prev.txt
+    # Save sequence file so we can rollback if an error occurs
+    cp sequence.txt sequence-prev.txt

 
     # Fetch the next set of changes
 
     # Fetch the next set of changes

-    osmosis --read-replication-interval --simc --write-xml-change file="${file}" compressionMethod="gzip"
+    pyosmium-get-changes --server=<%= node[:tile][:replication][:url] %> --sequence-file=sequence.txt --outfile=${file}
+
+    # Save exit status
+    status=$?

 
     # Check for errors
 
     # Check for errors

-    if [ $? -eq 0 ]
+    if [ $status -eq 0 ]

     then
         # Enable exit on error
         set -e
 
     then
         # Enable exit on error
         set -e
 

-        # Remember the previous sequence number
-        prevSequenceNumber=$sequenceNumber
-
-        # Read in new state
-        . state.txt
+        # Log the new data
+        echo "Fetched new data from $(cat sequence-prev.txt) to $(cat sequence.txt) into ${file}"

 
 

-        # Did we get any new data?
-        if [ "${sequenceNumber}" == "${prevSequenceNumber}" ]
-        then
-            # Log the lack of data
-            echo "No new data available. Sleeping..."
-
-            # Remove file, it will just be an empty changeset
-            rm ${file}
-
-            # No need to rollback now
-            rm state-prev.txt
-
-            # Sleep for a short while
-            sleep 30
-        else
-            # Log the new data
-            echo "Fetched new data from ${prevSequenceNumber} to ${sequenceNumber} into ${file}"
-
-            # Apply the changes to the database
-<% if node[:tile][:node_file] -%>
-            osm2pgsql --slim --append --number-processes=1 --flat-nodes=<%= node[:tile][:node_file] %> ${file}
-<% else -%>
-            osm2pgsql --slim --append --number-processes=1 ${file}
+        # Apply the changes to the database
+        osm2pgsql --database gis --slim --append --number-processes=1 \
+<% if node[:tile][:database][:node_file] -%>
+                  --flat-nodes=<%= node[:tile][:database][:node_file] %> \
+<% end -%>
+<% if node[:tile][:database][:multi_geometry] -%>
+                  --multi-geometry \
+<% end -%>
+<% if node[:tile][:database][:hstore] -%>
+                  --hstore \
+<% end -%>
+<% if node[:tile][:database][:style_file] -%>
+                  --style=<%= node[:tile][:database][:style_file] %> \

 <% end -%>
 <% end -%>

+<% if node[:tile][:database][:tag_transform_script] -%>
+                  --tag-transform-script=<%= node[:tile][:database][:tag_transform_script] %> \
+<% end -%>
+                  ${file}
+
+        # No need to rollback now
+        rm sequence-prev.txt

 
 

-            # No need to rollback now
-            rm state-prev.txt
+        # Get buffer count
+        buffers=$(osmium fileinfo --extended --get=data.buffers.count ${file})

 
 

-            # Expire tiles which are touched by the changes
-            sudo -u www-data /usr/local/bin/expire-tiles ${file} > /dev/null 2>&1 &
+        # If this diff has content mark it as the latest diff
+        if [ $buffers -gt 0 ]
+        then
+            ln -f ${file} changes-latest.osc.gz

         fi
 
         fi
 

+        # Queue these changes for expiry processing
+        ln ${file} expire-queue/${file}
+

         # Delete old downloads
         find . -name 'changes-*.gz' -mmin +300 -exec rm -f {} \;
 
         # Disable exit on error
         set +e
         # Delete old downloads
         find . -name 'changes-*.gz' -mmin +300 -exec rm -f {} \;
 
         # Disable exit on error
         set +e

+    elif [ $status -eq 3 ]
+    then
+        # Log the lack of data
+        echo "No new data available. Sleeping..."
+
+        # Remove file, it will just be an empty changeset
+        rm ${file}
+
+        # Sleep for a short while
+        sleep 30

     else
         # Log our failure to fetch changes
         echo "Failed to fetch changes - waiting a few minutes before retry"
 
     else
         # Log our failure to fetch changes
         echo "Failed to fetch changes - waiting a few minutes before retry"
 

+        # Remove any output that was produced
+        rm -f ${file}
+

         # Wait five minutes and have another go
         sleep 300
     fi
         # Wait five minutes and have another go
         sleep 300
     fi