I0669 aggregate volumes 15min mvt tries to insert duplicate values

[gabrielwol]

What this pull request accomplishes:

• Adds new function miovision_api.aggregate_15_min_mvt_single_intersection to aggregate just a single intersection into volumes_15min_mvt.
• Improvements to existing miovision_api.aggregate_15_min_mvt function

Issue(s) this solves:

• Closes aggregate-volumes_15min_mvt tries to insert duplicate values #669

What, in particular, needs to reviewed:

• Fluffed and unnested the CTE in base function https://github.com/CityofToronto/bdit_data-sources/blob/09130027d9b2ab637dd4876663d804467757909d/volumes/miovision/sql/function-aggregate-volumes_15min_mvt.sql

• Duplicated new base function but added an intersection function argument and added an anti join to new function to prevent adding duplicate 0 padded values. function-aggregate-volumes_15min_mvt_single_intersection.sql
  

  bdit_data-sources/volumes/miovision/sql/function-aggregate-volumes_15min_mvt_single_intersection.sql

  Lines 38 to 41 in 0913002

  	--add an anti join on destination table to prevent duplicate key errors with zero padding movements.
  	LEFT JOIN miovision_api.volumes_15min_mvt AS v15mvt USING (
  	intersection_uid, datetime_bin, classification_uid, leg, movement_uid
  	)

  
  WHERE...
  

  bdit_data-sources/volumes/miovision/sql/function-aggregate-volumes_15min_mvt_single_intersection.sql

  Lines 72 to 73 in 0913002

  	--exclude values already in destination table
  	AND v15mvt.intersection_uid IS NULL

• Updated master...i0669-aggregate-volumes_15min_mvt-tries-to-insert-duplicate-values to use the new single intersection function if intersections are specified in function call.

What needs to be done by a sysadmin after this PR is merged

• Update definition of miovision_api.aggregate_15_min_mvt
• Add new function miovision_api.aggregate_15_min_mvt_single_intersection

[radumas]

Great work! All the SQL looks good, just a minor issue in cur.execute

[gabrielwol]

Ready for re-review!

[chmnata]

Changes applied on postgres + airflow