diff --git a/app/models.py b/app/models.py
index 5ab742b4f..db5bb1a1e 100644
--- a/app/models.py
+++ b/app/models.py
@@ -619,7 +619,7 @@ class JobStatus(db.Model):
 class Job(db.Model):
     __tablename__ = 'jobs'
 
-    id = db.Column(UUID(as_uuid=True), primary_key=True)
+    id = db.Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
     original_file_name = db.Column(db.String, nullable=False)
     service_id = db.Column(UUID(as_uuid=True), db.ForeignKey('services.id'), index=True, unique=False, nullable=False)
     service = db.relationship('Service', backref=db.backref('jobs', lazy='dynamic'))
diff --git a/app/notifications/process_letter_notifications.py b/app/notifications/process_letter_notifications.py
new file mode 100644
index 000000000..358df8771
--- /dev/null
+++ b/app/notifications/process_letter_notifications.py
@@ -0,0 +1,41 @@
+from app import create_random_identifier
+from app.models import LETTER_TYPE, JOB_STATUS_READY_TO_SEND
+from app.notifications.process_notifications import persist_notification
+
+
+def create_letter_api_job(template):
+    service = template.service
+    if not service.active:
+        raise InvalidRequest('Create job is not allowed: service is inactive', 403)
+    if template.archived:
+        raise InvalidRequest('Create job is not allowed: template is deleted', 400)
+
+
+    job = Job(
+        original_file_name='letter submitted via api',
+        service=service,
+        template=template,
+        template_version=template.version,
+        notification_count=1,
+        job_status=JOB_STATUS_READY_TO_SEND,
+        created_by=None
+    )
+    dao_create_job(job)
+
+
+def create_letter_notification(letter_data, job, api_key):
+    notification = persist_notification(
+        template_id=job.template.id,
+        template_version=job.template.version,
+        recipient=letter_data['personalisation']['address line 1'],  # or addressline1 or address_line_1?
+        service=job.service,
+        personalisation=letter_data['personalisation'],
+        notification_type=LETTER_TYPE,
+        api_key_id=api_key.id,
+        key_type=api_key.key_type,
+        job_id=job.id,
+        job_row_number=0,
+        reference=create_random_identifier(),
+        client_reference=letter_data.get('reference')
+    )
+    return notification
diff --git a/app/notifications/process_notifications.py b/app/notifications/process_notifications.py
index 19430c386..e7e8779f2 100644
--- a/app/notifications/process_notifications.py
+++ b/app/notifications/process_notifications.py
@@ -55,7 +55,7 @@ def persist_notification(
     created_by_id=None
 ):
     notification_created_at = created_at or datetime.utcnow()
-    if not notification_id and simulated:
+    if not notification_id:
         notification_id = uuid.uuid4()
     notification = Notification(
         id=notification_id,
diff --git a/app/v2/notifications/post_notifications.py b/app/v2/notifications/post_notifications.py
index f39f54345..502f2aa4d 100644
--- a/app/v2/notifications/post_notifications.py
+++ b/app/v2/notifications/post_notifications.py
@@ -5,11 +5,16 @@ from flask import request, jsonify, current_app, abort
 from app import api_user, authenticated_service
 from app.config import QueueNames
 from app.models import SMS_TYPE, EMAIL_TYPE, LETTER_TYPE, PRIORITY
+from app.celery.tasks import build_dvla_file
 from app.notifications.process_notifications import (
     persist_notification,
     send_notification_to_queue,
     simulated_recipient,
     persist_scheduled_notification)
+from app.notifications.process_letter_notifications import (
+    create_letter_api_job,
+    create_letter_notification
+)
 from app.notifications.validators import (
     validate_and_format_recipient,
     check_rate_limiting,
@@ -58,10 +63,9 @@ def post_notification(notification_type):
 
     if notification_type == LETTER_TYPE:
         notification = process_letter_notification(
-            form=form,
+            letter_data=form,
             api_key=api_user,
             template=template,
-            service=authenticated_service,
         )
     else:
         notification = process_sms_or_email_notification(
@@ -140,10 +144,12 @@ def process_sms_or_email_notification(*, form, notification_type, api_key, templ
     return notification
 
 
-def process_letter_notification(*, form, api_key, template, service):
-    # create job
-
-    # create notification
-
-    # trigger build_dvla_file task
-    raise NotImplementedError
+def process_letter_notification(*, letter_data, api_key, template, service):
+    job = create_letter_api_job(template)
+    notification = create_letter_notification(letter_data, job, api_key)
+    build_dvla_file.apply_async([str(job.id)], queue=QueueNames.JOBS)
+    current_app.logger.info("send job {} for api notification {} to build-dvla-file in the process-job queue".format(
+        job.id,
+        notification.id
+    ))
+    return notification