|
1
|
|
|
"""MLLM (Maui-like Lexical Matchin) model for Annif""" |
|
2
|
|
|
|
|
3
|
|
|
import collections |
|
4
|
|
|
import math |
|
5
|
|
|
import joblib |
|
6
|
|
|
from statistics import mean |
|
7
|
|
|
from enum import IntEnum |
|
8
|
|
|
import numpy as np |
|
9
|
|
|
from rdflib import URIRef |
|
10
|
|
|
from rdflib.namespace import SKOS |
|
11
|
|
|
from scipy.sparse import lil_matrix, csc_matrix |
|
12
|
|
|
from sklearn.feature_extraction.text import CountVectorizer |
|
13
|
|
|
from sklearn.ensemble import BaggingClassifier |
|
14
|
|
|
from sklearn.tree import DecisionTreeClassifier |
|
15
|
|
|
import annif.util |
|
16
|
|
|
from annif.lexical.tokenset import TokenSet, TokenSetIndex |
|
17
|
|
|
|
|
18
|
|
|
|
|
19
|
|
|
Term = collections.namedtuple('Term', 'subject_id label is_pref') |
|
20
|
|
|
|
|
21
|
|
|
Match = collections.namedtuple( |
|
22
|
|
|
'Match', 'subject_id is_pref n_tokens pos ambiguity') |
|
23
|
|
|
|
|
24
|
|
|
Candidate = collections.namedtuple( |
|
25
|
|
|
'Candidate', |
|
26
|
|
|
'doc_length subject_id freq is_pref n_tokens ambiguity ' + |
|
27
|
|
|
'first_occ last_occ spread') |
|
28
|
|
|
|
|
29
|
|
|
Feature = IntEnum( |
|
30
|
|
|
'Feature', |
|
31
|
|
|
'freq doc_freq subj_freq tfidf is_pref n_tokens ambiguity ' + |
|
32
|
|
|
'first_occ last_occ spread doc_length ' + |
|
33
|
|
|
'broader narrower related collection', |
|
34
|
|
|
start=0) |
|
35
|
|
|
|
|
36
|
|
|
|
|
37
|
|
|
def get_subject_labels(graph, uri, properties, language): |
|
38
|
|
|
for prop in properties: |
|
39
|
|
|
for label in graph.objects(URIRef(uri), prop): |
|
40
|
|
|
if label.language != language: |
|
41
|
|
|
continue |
|
42
|
|
|
yield str(label) |
|
43
|
|
|
|
|
44
|
|
|
|
|
45
|
|
|
class MLLMModel: |
|
46
|
|
|
"""Maui-like Lexical Matching model""" |
|
47
|
|
|
|
|
48
|
|
|
def _conflate_matches(self, matches, doc_length): |
|
49
|
|
|
subj_matches = collections.defaultdict(list) |
|
50
|
|
|
for match in matches: |
|
51
|
|
|
subj_matches[match.subject_id].append(match) |
|
52
|
|
|
return [ |
|
53
|
|
|
Candidate( |
|
54
|
|
|
doc_length=doc_length, |
|
55
|
|
|
subject_id=subject_id, |
|
56
|
|
|
freq=len(matches) / doc_length, |
|
57
|
|
|
is_pref=mean((float(m.is_pref) for m in matches)), |
|
58
|
|
|
n_tokens=mean((m.n_tokens for m in matches)), |
|
59
|
|
|
ambiguity=mean((m.ambiguity for m in matches)), |
|
60
|
|
|
first_occ=matches[0].pos / doc_length, |
|
61
|
|
|
last_occ=matches[-1].pos / doc_length, |
|
62
|
|
|
spread=(matches[-1].pos - matches[0].pos) / doc_length |
|
63
|
|
|
) |
|
64
|
|
|
for subject_id, matches in subj_matches.items()] |
|
65
|
|
|
|
|
66
|
|
|
def generate_candidates(self, text, analyzer): |
|
67
|
|
|
sentences = analyzer.tokenize_sentences(text) |
|
68
|
|
|
sent_tokens = self._vectorizer.transform(sentences) |
|
69
|
|
|
matches = [] |
|
70
|
|
|
|
|
71
|
|
|
for sent_idx, token_matrix in enumerate(sent_tokens): |
|
72
|
|
|
tset = TokenSet(token_matrix.nonzero()[1]) |
|
73
|
|
|
for ts, ambiguity in self._index.search(tset): |
|
74
|
|
|
matches.append(Match(subject_id=ts.subject_id, |
|
75
|
|
|
is_pref=ts.is_pref, |
|
76
|
|
|
n_tokens=len(ts), |
|
77
|
|
|
pos=sent_idx, |
|
78
|
|
|
ambiguity=ambiguity)) |
|
79
|
|
|
|
|
80
|
|
|
return self._conflate_matches(matches, len(sentences)) |
|
81
|
|
|
|
|
82
|
|
|
def _candidates_to_features(self, candidates): |
|
83
|
|
|
"""Convert a list of Candidates to a NumPy feature matrix""" |
|
84
|
|
|
matrix = np.zeros((len(candidates), len(Feature)), dtype=np.float32) |
|
85
|
|
|
c_ids = [c.subject_id for c in candidates] |
|
86
|
|
|
c_vec = np.zeros(self._related_matrix.shape[0], dtype=np.bool) |
|
87
|
|
|
c_vec[c_ids] = True |
|
88
|
|
|
broader = self._broader_matrix.multiply(c_vec).sum(axis=1) |
|
89
|
|
|
narrower = self._narrower_matrix.multiply(c_vec).sum(axis=1) |
|
90
|
|
|
related = self._related_matrix.multiply(c_vec).sum(axis=1) |
|
91
|
|
|
collection = self._collection_matrix.multiply(c_vec).T.dot( |
|
92
|
|
|
self._collection_matrix).sum(axis=0) |
|
93
|
|
|
for idx, c in enumerate(candidates): |
|
94
|
|
|
subj = c.subject_id |
|
95
|
|
|
matrix[idx, Feature.freq] = c.freq |
|
96
|
|
|
matrix[idx, Feature.doc_freq] = self._doc_freq[subj] |
|
97
|
|
|
matrix[idx, Feature.subj_freq] = self._subj_freq.get(subj, 1) - 1 |
|
98
|
|
|
matrix[idx, Feature.tfidf] = c.freq * self._idf[subj] |
|
99
|
|
|
matrix[idx, Feature.is_pref] = c.is_pref |
|
100
|
|
|
matrix[idx, Feature.n_tokens] = c.n_tokens |
|
101
|
|
|
matrix[idx, Feature.ambiguity] = c.ambiguity |
|
102
|
|
|
matrix[idx, Feature.first_occ] = c.first_occ |
|
103
|
|
|
matrix[idx, Feature.last_occ] = c.last_occ |
|
104
|
|
|
matrix[idx, Feature.spread] = c.spread |
|
105
|
|
|
matrix[idx, Feature.doc_length] = c.doc_length |
|
106
|
|
|
matrix[idx, Feature.broader] = broader[subj, 0] / len(c_ids) |
|
107
|
|
|
matrix[idx, Feature.narrower] = narrower[subj, 0] / len(c_ids) |
|
108
|
|
|
matrix[idx, Feature.related] = related[subj, 0] / len(c_ids) |
|
109
|
|
|
matrix[idx, Feature.collection] = collection[0, subj] / len(c_ids) |
|
110
|
|
|
return matrix |
|
111
|
|
|
|
|
112
|
|
|
def _prepare_terms(self, graph, vocab, params): |
|
113
|
|
|
if annif.util.boolean(params['use_hidden_labels']): |
|
114
|
|
|
label_props = [SKOS.altLabel, SKOS.hiddenLabel] |
|
115
|
|
|
else: |
|
116
|
|
|
label_props = [SKOS.altLabel] |
|
117
|
|
|
|
|
118
|
|
|
terms = [] |
|
119
|
|
|
subject_ids = [] |
|
120
|
|
|
for subj_id, uri, pref, _ in vocab.subjects.active: |
|
121
|
|
|
subject_ids.append(subj_id) |
|
122
|
|
|
terms.append(Term(subject_id=subj_id, label=pref, is_pref=True)) |
|
123
|
|
|
|
|
124
|
|
|
for label in get_subject_labels(graph, uri, label_props, |
|
125
|
|
|
params['language']): |
|
126
|
|
|
terms.append(Term(subject_id=subj_id, |
|
127
|
|
|
label=label, |
|
128
|
|
|
is_pref=False)) |
|
129
|
|
|
|
|
130
|
|
|
return (terms, subject_ids) |
|
131
|
|
|
|
|
132
|
|
|
def _make_relation_matrix(self, graph, vocab, property): |
|
133
|
|
|
n_subj = len(vocab.subjects) |
|
134
|
|
|
matrix = lil_matrix((n_subj, n_subj), dtype=np.bool) |
|
135
|
|
|
|
|
136
|
|
|
for subj, obj in graph.subject_objects(property): |
|
137
|
|
|
subj_id = vocab.subjects.by_uri(str(subj), warnings=False) |
|
138
|
|
|
obj_id = vocab.subjects.by_uri(str(obj), warnings=False) |
|
139
|
|
|
if subj_id is not None and obj_id is not None: |
|
140
|
|
|
matrix[subj_id, obj_id] = True |
|
141
|
|
|
|
|
142
|
|
|
return csc_matrix(matrix) |
|
143
|
|
|
|
|
144
|
|
|
def _make_collection_matrix(self, graph, vocab): |
|
145
|
|
|
# make an index with all collection members |
|
146
|
|
|
c_members = collections.defaultdict(list) |
|
147
|
|
|
for coll, member in graph.subject_objects(SKOS.member): |
|
148
|
|
|
member_id = vocab.subjects.by_uri(str(member), warnings=False) |
|
149
|
|
|
if member_id is not None: |
|
150
|
|
|
c_members[str(coll)].append(member_id) |
|
151
|
|
|
|
|
152
|
|
|
c_matrix = lil_matrix((len(c_members), len(vocab.subjects)), |
|
153
|
|
|
dtype=np.bool) |
|
154
|
|
|
|
|
155
|
|
|
# populate the matrix for collection -> subject_id |
|
156
|
|
|
for c_id, members in enumerate(c_members.values()): |
|
157
|
|
|
c_matrix[c_id, members] = True |
|
158
|
|
|
|
|
159
|
|
|
return csc_matrix(c_matrix) |
|
160
|
|
|
|
|
161
|
|
|
def _prepare_relations(self, graph, vocab): |
|
162
|
|
|
self._broader_matrix = self._make_relation_matrix( |
|
163
|
|
|
graph, vocab, SKOS.broader) |
|
164
|
|
|
self._narrower_matrix = self._make_relation_matrix( |
|
165
|
|
|
graph, vocab, SKOS.narrower) |
|
166
|
|
|
self._related_matrix = self._make_relation_matrix( |
|
167
|
|
|
graph, vocab, SKOS.related) |
|
168
|
|
|
self._collection_matrix = self._make_collection_matrix(graph, vocab) |
|
169
|
|
|
|
|
170
|
|
|
def _prepare_train_index(self, vocab, analyzer, params): |
|
171
|
|
|
graph = vocab.as_graph() |
|
172
|
|
|
terms, subject_ids = self._prepare_terms(graph, vocab, params) |
|
173
|
|
|
self._prepare_relations(graph, vocab) |
|
174
|
|
|
|
|
175
|
|
|
self._vectorizer = CountVectorizer( |
|
176
|
|
|
binary=True, |
|
177
|
|
|
tokenizer=analyzer.tokenize_words |
|
178
|
|
|
) |
|
179
|
|
|
label_corpus = self._vectorizer.fit_transform((t.label for t in terms)) |
|
180
|
|
|
|
|
181
|
|
|
self._index = TokenSetIndex() |
|
182
|
|
|
for term, label_matrix in zip(terms, label_corpus): |
|
183
|
|
|
tokens = label_matrix.nonzero()[1] |
|
184
|
|
|
tset = TokenSet(tokens, term.subject_id, term.is_pref) |
|
185
|
|
|
self._index.add(tset) |
|
186
|
|
|
|
|
187
|
|
|
return subject_ids |
|
188
|
|
|
|
|
189
|
|
|
def _calculate_idf(self, subject_ids, doc_count): |
|
190
|
|
|
idf = collections.defaultdict(float) |
|
191
|
|
|
for subj_id in subject_ids: |
|
192
|
|
|
idf[subj_id] = math.log((doc_count + 1) / |
|
193
|
|
|
(self._doc_freq[subj_id] + 1)) + 1 |
|
194
|
|
|
|
|
195
|
|
|
return idf |
|
196
|
|
|
|
|
197
|
|
|
def prepare_train(self, corpus, vocab, analyzer, params): |
|
198
|
|
|
subject_ids = self._prepare_train_index(vocab, analyzer, params) |
|
199
|
|
|
|
|
200
|
|
|
# frequency of subjects (by id) in the generated candidates |
|
201
|
|
|
self._doc_freq = collections.Counter() |
|
202
|
|
|
# frequency of manually assigned subjects ("domain keyphraseness") |
|
203
|
|
|
self._subj_freq = collections.Counter() |
|
204
|
|
|
doc_count = 0 |
|
205
|
|
|
train_x = [] |
|
206
|
|
|
train_y = [] |
|
207
|
|
|
for idx, doc in enumerate(corpus.documents): |
|
208
|
|
|
doc_subject_ids = [vocab.subjects.by_uri(uri) |
|
209
|
|
|
for uri in doc.uris] |
|
210
|
|
|
self._subj_freq.update(doc_subject_ids) |
|
211
|
|
|
candidates = self.generate_candidates(doc.text, analyzer) |
|
212
|
|
|
self._doc_freq.update([c.subject_id for c in candidates]) |
|
213
|
|
|
train_x.append(candidates) |
|
214
|
|
|
train_y += [(c.subject_id in doc_subject_ids) for c in candidates] |
|
215
|
|
|
doc_count += 1 |
|
216
|
|
|
|
|
217
|
|
|
# precalculate idf values for all candidate subjects |
|
218
|
|
|
self._idf = self._calculate_idf(subject_ids, doc_count) |
|
219
|
|
|
|
|
220
|
|
|
return (np.vstack([self._candidates_to_features(candidates) |
|
221
|
|
|
for candidates in train_x]), np.array(train_y)) |
|
222
|
|
|
|
|
223
|
|
|
def _create_classifier(self, params): |
|
224
|
|
|
return BaggingClassifier( |
|
225
|
|
|
DecisionTreeClassifier( |
|
226
|
|
|
min_samples_leaf=int(params['min_samples_leaf']), |
|
227
|
|
|
max_leaf_nodes=int(params['max_leaf_nodes']) |
|
228
|
|
|
), max_samples=float(params['max_samples'])) |
|
229
|
|
|
|
|
230
|
|
|
def train(self, train_x, train_y, params): |
|
231
|
|
|
# fit the model on the training corpus |
|
232
|
|
|
self._classifier = self._create_classifier(params) |
|
233
|
|
|
self._classifier.fit(train_x, train_y) |
|
234
|
|
|
|
|
235
|
|
|
def _prediction_to_list(self, scores, candidates): |
|
236
|
|
|
subj_scores = [(score[1], c.subject_id) |
|
237
|
|
|
for score, c in zip(scores, candidates)] |
|
238
|
|
|
return sorted(subj_scores, reverse=True) |
|
239
|
|
|
|
|
240
|
|
|
def predict(self, candidates): |
|
241
|
|
|
if not candidates: |
|
242
|
|
|
return [] |
|
243
|
|
|
features = self._candidates_to_features(candidates) |
|
244
|
|
|
scores = self._classifier.predict_proba(features) |
|
245
|
|
|
return self._prediction_to_list(scores, candidates) |
|
246
|
|
|
|
|
247
|
|
|
def save(self, filename): |
|
248
|
|
|
return joblib.dump(self, filename) |
|
249
|
|
|
|
|
250
|
|
|
@staticmethod |
|
251
|
|
|
def load(filename): |
|
252
|
|
|
return joblib.load(filename) |
|
253
|
|
|
|
NatLibFi /
Annif
