Commit a719b6fb authored by Ignacio's avatar Ignacio
Browse files

Añade mmsi, tstamp como clave primaria de last_week

parent 21bac217

scripts/docker-entrypoint.sh

+1 −1
Original line number Diff line number Diff line
@@ -23,7 +23,7 @@ while [[ "${done}" = false ]]; do 
				"http://${addr}/connectors" >& /dev/null



			curl -s -X POST -H "Content-Type: application/json" --data \

				"{\"name\": \"jdbc-ais-last-week-sink\", \"config\": {\"name\":\"jdbc-ais-last-week-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"last_week\", \"auto.evolve\": \"true\"}}" \

				"{\"name\": \"jdbc-ais-last-week-sink\", \"config\": {\"name\":\"jdbc-ais-last-week-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"last_week\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi,tstamp\"}}" \

				"http://${addr}/connectors" >& /dev/null

			break

		fi