LDV Specification

LDV Specification Application. For filling ATDB-LDV with processing tasks for LOFAR data

Documentation (Confluence)

• The plan: https://support.astron.nl/confluence/pages/viewpage.action?pageId=84215267

• https://support.astron.nl/confluence/display/SDCP/LDV+Documentation

• deployment diagram of the current situation (in production)

  • https://drive.google.com/file/d/1_j9Fp505pZTxcmzAEdgftdPkoIFrKfAX/view?usp=sharing

Collaborate

• create your branch from main

• add your functionality

• test your functionality locally

• merge main into your branch before creating a MR

• merge with main

• deploy in test, and test it

• deploy in production, and test it

Local update

After a colleague has made changes, then locally:

  > git pull
  > pip install -r requirements\dev.txt
  > python manage.py migrate --settings=ldvspec.settings.dev

Run migration

docker exec -ti ldv-specification python manage.py migrate --settings ldvspec.settings.docker_sdc

Local Development Environment

Start developing

• Copy the ldvspec.example.env, rename it to ldvspec.env and fill in the variables. The variables should match the local.py settings which are coherent with the docker-compose-local.yml setup.
• Run docker-compose -f docker-compose-local.yml up -d with the following compose file to spin up a new Postgres container, celery worker and rabbitMQ.
• Run the following python command to start developing

  python manage.py migrate --settings=ldvspec.settings.local

  python manage.py createsuperuser --settings=ldvspec.settings.local

  python manage.py runserver --settings=ldvspec.settings.local

-[ ] TODO: load fixture to have sample data

Django Application

• clone the repo

• open the project in Pycharm

• create a venv (File -> Settings -> Project -> Project Interpreter -> (click cog) -> add)

• pip install -r requirements\dev.txt

• check and/or change the database connection in settings/dev/py. In this example it connects to a database server on 'raspiastro', you have to change that to the server where you run your Postgres Docker container (localhost?)

DATABASES = {
    'default': {
         'ENGINE': 'django.db.backends.postgresql_psycopg2',
         'USER': 'postgres',
         'PASSWORD': 'secret',
         'NAME': 'ldv-spec-db',
         'HOST': 'raspiastro',
         'PORT': '5433',
    },
}

   > python manage.py migrate --settings=ldvspec.settings.dev
   > python manage.py createsuperuser --settings=ldvspec.settings.dev
   > python manage.py runserver --settings=ldvspec.settings.dev

   # In another terminal (for background tasks):
   > celery -A ldvspec worker -l INFO
   # Note: for windows you might need to add the `--pool=solo` parameter

Test Environment

• https://sdc-dev.astron.nl/ldvspec/

Production Environment

• https://sdc.astron.nl/ldvspec/

Configuration

See ~/shared/ldvspec.env for database credentials and where to find ATDB-LDV

NOTE: currently a postgres database in a Docker container is also used in production. This will change to a database on the sdc-db machine.

admin user

• admin:admin

Build & Deploy

The CI/CD pipeline creates 2 Docker containers:

• ldv-specification : The Django application
• ldv-spec-postgres : The Postgres database

The database can also be accessed externally:

• host : sdc-dev.astron.nl / sdc.astron.nl
• port : 12000
• database: ldv-spec-db

Manual steps (add them somewhere)

Log into the ldv-specification container. (using the portainer GUI or with the docker exec)

• https://sdc-dev.astron.nl/portainer/
• https://sdc.astron.nl/portainer/#/home

> cd /src
> python manage.py migrate --settings=ldvspec.settings.docker_sdc
> python manage.py createsuperuser --settings=ldvspec.settings.docker_sdc

Usage

See also:

• https://support.astron.nl/confluence/display/SDCP/API+dynamics

Add a work specification

With this url you can specify work

• http://127.0.0.1:8000/ldvspec/api/v1/workspecification/

This is an example of structure of the LOFAR data in the ldv-spec-db database. Which also shows which fields can be used to filter on.

• http://127.0.0.1:8000/ldvspec/api/v1/data/

GET /ldvspec/api/v1/data/
HTTP 200 OK
Allow: GET, POST, HEAD, OPTIONS
Content-Type: application/json
Vary: Accept

{
    "count": 10010,
    "next": "http://127.0.0.1:8000/ldvspec/api/v1/data/?page=2",
    "previous": null,
    "results": [
        {
            "id": 3155,
            "obs_id": "102092",
            "oid_source": "SAS",
            "dataproduct_source": "LOFAR LTA",
            "dataproduct_type": "Correlator data",
            "project": "LC0_043",
            "activity": "Raw Observation",
            "surl": "srm://lofar-srm.fz-juelich.de:8443/pnfs/fz-juelich.de/data/lofar/ops/projects/lc0_043/102092/L102092_SAP000_SB261_uv.MS_8d9ea7c0.tar",
            "filesize": 1477939200,
            "additional_meta": "{'dysco_compression': False}",
            "location": "Juelich"
        },

• Enter the filter in json format in the filter textbox, for example {"obs_id": 102092, "additional_meta__dysco_compression": true}

• Choose valid workflow, for example imaging_compress_pipeline_v02 (see the worklows endpoint in the ATDB API for an overview of valid workflows: https://sdc.astron.nl:5554/atdb/workflows/)

• After clicking 'POST', the response should look like this.

HTTP 201 Created
Allow: GET, POST, HEAD, OPTIONS
Content-Type: application/json
Vary: Accept

{
    "id": 2,
    "created_on": "2022-08-15T07:07:39.479546Z",
    "filters": {
        "obs_id": 102092,
        "additional_meta__dysco_compression": true
    },
    "inputs": null,
    "selected_workflow": "imaging_compress_pipeline_v02",
    "related_tasks": null,
    "is_ready": false,
    "is_defined": false,
    "async_task_result": "99622e7b-71f0-4f05-826d-23c13846642d",
    "created_by": 1,
    "processing_site": null
}

The workspecification endpoint now shows an overview of specified work, which is ready to be sent to ATDB-LDV:

• http://127.0.0.1:8000/ldvspec/api/v1/workspecification/

Troubleshooting

Q: OperationalError at /ldvspec/api/v1/workspecification/ [WinError 10061] No connection could be made because the target machine actively refused it

A: make sure that you have a connection to a celery broker (RabbitMQ) when running the application in development mode.

Example on Windows machine:

SET CELERY_BROKER_URL=amqp://guest@raspiastro:5672
python manage.py runserver --settings=ldvspec.settings.dev