add model from reinforcement learning for topic models

octis/models/RLTM.py

@@ -0,0 +1,255 @@
+from sklearn.feature_extraction.text import CountVectorizer
+
+from octis.models.model import AbstractModel
+from octis.models.rl_for_topic_models.datasets import dataset
+from octis.models.rl_for_topic_models.models import rltm
+from octis.models.rl_for_topic_models.utils.data_preparation import (
+    bert_embeddings_from_list)
+
+import os
+import pickle as pkl
+import torch
+import numpy as np
+import random
+
+
+class RLTM(AbstractModel):
+
+    def __init__(
+        self, num_topics=10, activation='gelu', num_layers=2, num_neurons=128,
+        inference_dropout=0.2, policy_dropout=0.0, batch_size=256, lr=3e-4,
+        momentum=0.9, solver='adamw', num_epochs=200, num_samples=10,
+        seed=None, use_partitions=True, reduce_on_plateau=False, bert_path="",
+        bert_model="all-MiniLM-L6-v2", weight_decay=0.01, kl_multiplier=1.0):
+        """
+        initialization of RLTM
+
+        :param num_topics : int, number of topic components, (default 10)
+        :param activation : string, 'softplus', 'relu', 'sigmoid',
+            'swish', 'tanh', 'leakyrelu', 'rrelu', 'elu', 'selu',
+            'gelu' (default 'gelu')
+        :param num_layers : int, number of layers (default 2)
+        :param num_neurons : int, number of neurons per layer (default 128)
+        :param inference_dropout : float, inference dropout to use (default 0.2)
+        :param policy_dropout : float, policy dropout to use (default 0.0)
+        :param batch_size : int, size of batch to use for training (default 256)
+        :param lr : float, learning rate to use for training (default 3e-4)
+        :param momentum : float, momentum to use for training (default 0.9)
+        :param solver: string, optimizer 'adagrad', 'adam', 'sgd', 'adadelta',
+            'rmsprop', 'adamw' (default 'adamw')
+        :param num_epochs : int, number of epochs to train for, (default 200)
+        :param num_samples: int, number of times theta needs to be sampled
+            (default: 10)
+        :param seed : int, the random seed. Not used if None (default None).
+        :param use_partitions: bool, if true the model will be trained on the
+            training set and evaluated on the test set (default: true)
+        :param reduce_on_plateau : bool, reduce learning rate by 10x on
+            plateau of 10 epochs (default False)
+        :param bert_path: path to store the document contextualized
+            representations
+        :param bert_model: name of the contextualized model
+            (default: all-MiniLM-L6-v2).
+            see https://www.sbert.net/docs/pretrained_models.html
+        :param weight_decay: float, L2 regularization on model weights
+        :param kl_multiplier: float or int, multiplier on the KL
+            divergence (default 1.0)
+        """
+
+        super().__init__()
+
+        self.hyperparameters['num_topics'] = num_topics
+        self.hyperparameters['activation'] = activation
+        self.hyperparameters['inference_dropout'] = inference_dropout
+        self.hyperparameters['policy_dropout'] = policy_dropout
+        self.hyperparameters['batch_size'] = batch_size
+        self.hyperparameters['lr'] = lr
+        self.hyperparameters['num_samples'] = num_samples
+        self.hyperparameters['momentum'] = momentum
+        self.hyperparameters['solver'] = solver
+        self.hyperparameters['num_epochs'] = num_epochs
+        self.hyperparameters['reduce_on_plateau'] = reduce_on_plateau
+        self.hyperparameters["num_neurons"] = num_neurons
+        self.hyperparameters["bert_path"] = bert_path
+        self.hyperparameters["num_layers"] = num_layers
+        self.hyperparameters["bert_model"] = bert_model
+        self.hyperparameters["seed"] = seed
+        self.hyperparameters["weight_decay"] = weight_decay
+        self.hyperparameters['kl_multiplier'] = kl_multiplier
+        self.use_partitions = use_partitions
+
+        hidden_sizes = tuple([num_neurons for _ in range(num_layers)])
+        self.hyperparameters['hidden_sizes'] = tuple(hidden_sizes)
+
+        self.model = None
+        self.vocab = None
+
+    def train_model(self, dataset, hyperparameters=None, top_words=10):
+        """
+        trains RLTM model
+
+        :param dataset: octis Dataset for training the model
+        :param hyperparameters: dict, with (optionally) the hyperparameters
+        :param top_words: number of top-n words of the topics (default 10)
+
+        """
+        if hyperparameters is None:
+            hyperparameters = {}
+
+        self.set_params(hyperparameters)
+        self.vocab = dataset.get_vocabulary()
+        self.set_seed(seed=self.hyperparameters['seed'])
+
+        if self.use_partitions:
+            train, validation, test = dataset.get_partitioned_corpus(
+                use_validation=True)
+
+            data_corpus_train = [' '.join(i) for i in train]
+            data_corpus_test = [' '.join(i) for i in test]
+            data_corpus_validation = [' '.join(i) for i in validation]
+
+            x_train, x_test, x_valid, input_size = self.preprocess(
+                self.vocab, data_corpus_train, test=data_corpus_test,
+                validation=data_corpus_validation,
+                bert_train_path=(
+                    self.hyperparameters['bert_path'] + "_train.pkl"),
+                bert_test_path=self.hyperparameters['bert_path'] + "_test.pkl",
+                bert_val_path=self.hyperparameters['bert_path'] + "_val.pkl",
+                bert_model=self.hyperparameters["bert_model"])
+
+            self.model = rltm.RLTM(
+                input_size=input_size, bert_size=x_train.X_bert.shape[1],
+                num_topics=self.hyperparameters['num_topics'],
+                hidden_sizes=self.hyperparameters['hidden_sizes'],
+                activation=self.hyperparameters['activation'],
+                inference_dropout=self.hyperparameters['inference_dropout'],
+                policy_dropout=self.hyperparameters['policy_dropout'],
+                batch_size=self.hyperparameters['batch_size'],
+                lr=self.hyperparameters['lr'],
+                momentum=self.hyperparameters['momentum'],
+                solver=self.hyperparameters['solver'],
+                num_epochs=self.hyperparameters['num_epochs'],
+                num_samples=self.hyperparameters['num_samples'],
+                reduce_on_plateau=self.hyperparameters['reduce_on_plateau'],
+                weight_decay=self.hyperparameters['weight_decay'],
+                kl_multiplier=self.hyperparameters['kl_multiplier'],
+                top_words=top_words)
+
+            self.model.fit(x_train, x_valid, verbose=False)
+            result = self.inference(x_test)
+            return result
+
+        else:
+            data_corpus = [' '.join(i) for i in dataset.get_corpus()]
+            x_train, input_size = self.preprocess(
+                self.vocab, train=data_corpus,
+                bert_train_path=(
+                    self.hyperparameters['bert_path'] + "_train.pkl"),
+                bert_model=self.hyperparameters["bert_model"])
+
+        self.model = rltm.RLTM(
+            input_size=input_size, bert_size=x_train.X_bert.shape[1],
+            num_topics=self.hyperparameters['num_topics'],
+            hidden_sizes=self.hyperparameters['hidden_sizes'],
+            activation=self.hyperparameters['activation'],
+            inference_dropout=self.hyperparameters['inference_dropout'],
+            policy_dropout=self.hyperparameters['policy_dropout'],
+            batch_size=self.hyperparameters['batch_size'],
+            lr=self.hyperparameters['lr'],
+            momentum=self.hyperparameters['momentum'],
+            solver=self.hyperparameters['solver'],
+            num_epochs=self.hyperparameters['num_epochs'],
+            num_samples=self.hyperparameters['num_samples'],
+            reduce_on_plateau=self.hyperparameters['reduce_on_plateau'],
+            weight_decay=self.hyperparameters['weight_decay'],
+            kl_multiplier=self.hyperparameters['kl_multiplier'],
+            top_words=top_words)
+
+        self.model.fit(x_train, None, verbose=False)
+        result = self.model.get_info()
+        return result
+
+    def set_params(self, hyperparameters):
+        for k in hyperparameters.keys():
+            if k in self.hyperparameters.keys() and k != 'hidden_sizes':
+                self.hyperparameters[k] = hyperparameters.get(
+                    k, self.hyperparameters[k])
+
+        self.hyperparameters['hidden_sizes'] = tuple(
+            [self.hyperparameters["num_neurons"] for _ in range(
+                self.hyperparameters["num_layers"])])
+
+    def inference(self, x_test):
+        assert isinstance(self.use_partitions, bool) and self.use_partitions
+        results = self.model.predict(x_test)
+        return results
+
+    def partitioning(self, use_partitions=False):
+        self.use_partitions = use_partitions
+
+    @staticmethod
+    def set_seed(seed=None):
+        if seed is not None:
+            torch.manual_seed(seed)
+            torch.cuda.manual_seed(seed)
+            np.random.seed(seed)
+            random.seed(seed)
+            torch.backends.cudnn.enabled = False
+            torch.backends.cudnn.deterministic = True
+
+    @staticmethod
+    def preprocess(
+        vocab, train, bert_model, test=None, validation=None,
+            bert_train_path=None, bert_test_path=None, bert_val_path=None):
+        vocab2id = {w: i for i, w in enumerate(vocab)}
+        vec = CountVectorizer(
+            vocabulary=vocab2id, token_pattern=r'(?u)\b[\w+|\-]+\b')
+        entire_dataset = train.copy()
+        if test is not None:
+            entire_dataset.extend(test)
+        if validation is not None:
+            entire_dataset.extend(validation)
+
+        vec.fit(entire_dataset)
+        idx2token = {v: k for (k, v) in vec.vocabulary_.items()}
+
+        x_train = vec.transform(train)
+        b_train = RLTM.load_bert_data(bert_train_path, train, bert_model)
+
+        train_data = dataset.RLTMDataset(x_train.toarray(), b_train, idx2token)
+        input_size = len(idx2token.keys())
+
+        if test is not None and validation is not None:
+            x_test = vec.transform(test)
+            b_test = RLTM.load_bert_data(bert_test_path, test, bert_model)
+            test_data = dataset.RLTMDataset(x_test.toarray(), b_test, idx2token)
+
+            x_valid = vec.transform(validation)
+            b_val = RLTM.load_bert_data(bert_val_path, validation, bert_model)
+            valid_data = dataset.RLTMDataset(
+                x_valid.toarray(), b_val, idx2token)
+            return train_data, test_data, valid_data, input_size
+        if test is None and validation is not None:
+            x_valid = vec.transform(validation)
+            b_val = RLTM.load_bert_data(bert_val_path, validation, bert_model)
+            valid_data = dataset.RLTMDataset(
+                x_valid.toarray(), b_val, idx2token)
+            return train_data, valid_data, input_size
+        if test is not None and validation is None:
+            x_test = vec.transform(test)
+            b_test = RLTM.load_bert_data(bert_test_path, test, bert_model)
+            test_data = dataset.RLTMDataset(x_test.toarray(), b_test, idx2token)
+            return train_data, test_data, input_size
+        if test is None and validation is None:
+            return train_data, input_size
+
+    @staticmethod
+    def load_bert_data(bert_path, texts, bert_model):
+        if bert_path is not None:
+            if os.path.exists(bert_path):
+                bert_ouput = pkl.load(open(bert_path, 'rb'))
+            else:
+                bert_ouput = bert_embeddings_from_list(texts, bert_model)
+                pkl.dump(bert_ouput, open(bert_path, 'wb'))
+        else:
+            bert_ouput = bert_embeddings_from_list(texts, bert_model)
+        return bert_ouput

octis/models/rl_for_topic_models/datasets/dataset.py

@@ -0,0 +1,37 @@
+import torch
+from torch.utils.data import Dataset
+import scipy.sparse
+
+
+class RLTMDataset(Dataset):
+
+    """Class to load RLTM dataset."""
+
+    def __init__(self, X, X_bert, idx2token):
+        """
+        Args
+            X : array-like, shape=(n_samples, n_features)
+                Document word matrix.
+        """
+        if X.shape[0] != len(X_bert):
+            raise Exception("Wait! BoW and Contextual Embeddings have different sizes! "
+                            "You might want to check if the BoW preparation method has removed some documents. ")
+
+        self.X = X
+        self.X_bert = X_bert
+        self.idx2token = idx2token
+
+    def __len__(self):
+        """Return length of dataset."""
+        return self.X.shape[0]
+
+    def __getitem__(self, i):
+        """Return sample from dataset at index i."""
+        if type(self.X[i]) == scipy.sparse.csr.csr_matrix:
+            X = torch.FloatTensor(self.X[i].todense())
+            X_bert = torch.FloatTensor(self.X_bert[i])
+        else:
+            X = torch.FloatTensor(self.X[i])
+            X_bert = torch.FloatTensor(self.X_bert[i])
+
+        return {'X': X, 'X_bert': X_bert}