Dean
/
Bookdata-tools
mirror of https://github.com/BoiseState/bookdata-tools


  
1

	
2

	
3

	
4

	
5

	
6

	
7

	
8

	
9

	
10

	
11

	
12

	
13

	
14

	
15

	
16

	
17

	
18

	
19

	
20

	
21

	
22

	
23

	
24

	
25

	
26

	
27

	
28

	
29

	
30

	
31

	
32

	
33

	
34

	
35

	
36

	
            import logging
from invoke import task

import support as s

_log = logging.getLogger(__name__)

dft_date = '20181104'


@task(s.init, s.build, name='import')
def import_viaf(c, date=dft_date, force=False):
    "Import VIAF data"
    s.start('viaf-import', force=force)
    _log.info('initializing VIAF schema')
    s.psql(c, 'viaf-schema.sql', True)
    infile = s.data_dir / f'viaf-{date}-clusters-marc21.xml.gz'
    _log.info('importing VIAF data from %s', infile)

    s.pipeline([
        [s.bdtool, 'parse-marc', '--db-schema', 'viaf', '-t', 'marc_field', '--line-mode', infile]
    ])
    s.finish('viaf-import')

@task(s.init)
def index(c, force=False):
    "Index VIAF data"
    s.check_prereq('viaf-import')
    s.start('viaf-index', force=force)
    _log.info('building VIAF indexes')
    s.psql(c, 'viaf-index.sql', True)
    s.finish('viaf-index')

@task(s.init, s.build)
def record_files(c, date=dft_date):
    s.booktool(c, 'hash', s.data_dir / f'viaf-{date}-clusters-marc21.xml.gz')