小匠第一周期打卡笔记-Task02

一、文本预处理

预处理通常包括四个步骤：

　　读入文本

　　分词

　　建立字典，将每个词映射到一个唯一的索引(index)

　　将文本从词的序列转换为索引的序列，方便输入模型

读入文本：

 1 import collections
 2 import re
 3 
 4 def read_time_machine():
 5     with open('/home/kesci/input/timemachine7163/timemachine.txt', 'r') as f:
 6         lines = [re.sub('[^a-z]+', ' ', line.strip().lower()) for line in f]
 7     return lines
 8 
 9 
10 lines = read_time_machine()
11 print('# sentences %d' % len(lines))

分词：

　　将一个句子划分成若干个词（token），转换为一个词的序列

 1 def tokenize(sentences, token='word'):
 2     """Split sentences into word or char tokens"""
 3     if token == 'word':
 4         return [sentence.split(' ') for sentence in sentences]
 5     elif token == 'char':
 6         return [list(sentence) for sentence in sentences]
 7     else:
 8         print('ERROR: unkown token type '+token)
 9 
10 tokens = tokenize(lines)
11 tokens[0:2]

建立字典：

　　将字符串转换为数字。先构建一个字典（vocabulary），将每个词映射到一个唯一的索引编号

 1 class Vocab(object):
 2     def __init__(self, tokens, min_freq=0, use_special_tokens=False):
 3         counter = count_corpus(tokens)  # : 
 4         self.token_freqs = list(counter.items())
 5         self.idx_to_token = []
 6         if use_special_tokens:
 7             # padding, begin of sentence, end of sentence, unknown
 8             self.pad, self.bos, self.eos, self.unk = (0, 1, 2, 3)
 9             self.idx_to_token += ['', '', '', '']
10         else:
11             self.unk = 0
12             self.idx_to_token += ['']
13         self.idx_to_token += [token for token, freq in self.token_freqs
14                         if freq >= min_freq and token not in self.idx_to_token]
15         self.token_to_idx = dict()
16         for idx, token in enumerate(self.idx_to_token):
17             self.token_to_idx[token] = idx
18 
19     def __len__(self):
20         return len(self.idx_to_token)
21 
22     def __getitem__(self, tokens):
23         if not isinstance(tokens, (list, tuple)):
24             return self.token_to_idx.get(tokens, self.unk)
25         return [self.__getitem__(token) for token in tokens]
26 
27     def to_tokens(self, indices):
28         if not isinstance(indices, (list, tuple)):
29             return self.idx_to_token[indices]
30         return [self.idx_to_token[index] for index in indices]
31 
32 def count_corpus(sentences):
33     tokens = [tk for st in sentences for tk in st]
34     return collections.Counter(tokens)  # 返回一个字典，记录每个词的出现次数

1 '''vocab = Vocab(tokens)
2 print(list(vocab.token_to_idx.items())[0:10])
3 [('', 0), ('the', 1), ('time', 2), ('machine', 3), ('by', 4), ('h', 5), ('g', 6), ('wells', 7), ('i', 8), ('traveller', 9)]'''

将词转为索引：

　　使用字典，将原文本中的句子从单词序列转换为索引序列

1 for i in range(8, 10):
2     print('words:', tokens[i])
3     print('indices:', vocab[tokens[i]])

小结：

　　用现有工具进行分词：

　　　　我们前面介绍的分词方式非常简单，它至少有以下几个缺点:

1. 　　标点符号通常可以提供语义信息，但是我们的方法直接将其丢弃了
2. 　　类似“shouldn't", "doesn't"这样的词会被错误地处理
3. 　　类似"Mr.", "Dr."这样的词会被错误地处理

　　　　我们可以通过引入更复杂的规则来解决这些问题，但是事实上，有一些现有的工具可以很好地进行分词，我们在这里简单介绍其中的两个：spaCy和NLTK。

　　无论 use_special_token 参数是否为真，都会使用特殊token——<unk>,用来表示未登录词。

　　句子长度统计与构建字典无关

二、语言模型

作用：给定一长度为T的词的序列W₁,W₂, W₃,....,W_T，语言模型的目标是评估该序列是否合理，即计算该序列的概率：

　　　　　　　　　　　　　　　　P(W₁,W₂, W₃,....,W_T)

概率大合理，小则不合理

语言模型：

　　假设序列W₁,W₂, W₃,....,W_T，每个词都是依次生成的，那么：P(W₁,W₂, W₃,....,W_T) = ∏^T_t=1P(w_t| w₁,....,w_t-1 )

　　语言模型的参数就是次的概率以及给定前几个词情况下的条件概率。设训练数据集为一个大型文本语料库，如维基百科的所有条目，词的概率可以通过该词在训练数据集中的相对词频来计算，例如，W₁ $w_{1}$

$n$ 　

　　马尔可夫假设：

　　　　一个词的出现只与前面 $n$

$n$ $n$ $n$

$n$

$n$

$n$

　　随机采样

　　　　每次从数据里随机采样一个小批量。其中批量大小batch_size是每个小批量的样本数，num_steps是每个样本所包含的时间步数。在随机采样中，每个样本是原始序列上任意截取的一段序列，相邻的两个随机小批量在原始序列上的位置不一定相毗邻。

　　相邻采样

　　　　在相邻采样中，相邻的两个随机小批量在原始序列上的位置相毗邻。

　　采样小结

$n$

$n$

1 idx_to_char = list(set(corpus_chars)) # 去重，得到索引到字符的映射
2 char_to_idx = {char: i for i, char in enumerate(idx_to_char)} # 字符到索引的映射
3 vocab_size = len(char_to_idx)
4 print(vocab_size)
5 
6 corpus_indices = [char_to_idx[char] for char in corpus_chars]  # 将每个字符转化为索引，得到一个索引的序列
7 sample = corpus_indices[: 20]
8 print('chars:', ''.join([idx_to_char[idx] for idx in sample]))
9 print('indices:', sample)

　　定义函数load_data_jay_lyrics :

 1 def load_data_jay_lyrics():
 2     with open('/home/kesci/input/jaychou_lyrics4703/jaychou_lyrics.txt') as f:
 3         corpus_chars = f.read()
 4     corpus_chars = corpus_chars.replace('
', ' ').replace('
', ' ')
 5     corpus_chars = corpus_chars[0:10000]
 6     idx_to_char = list(set(corpus_chars))
 7     char_to_idx = dict([(char, i) for i, char in enumerate(idx_to_char)])
 8     vocab_size = len(char_to_idx)
 9     corpus_indices = [char_to_idx[char] for char in corpus_chars]
10     return corpus_indices, char_to_idx, idx_to_char, vocab_size

　　随机取样：

 1 import torch
 2 import random
 3 def data_iter_random(corpus_indices, batch_size, num_steps, device=None):
 4     # 减1是因为对于长度为n的序列，X最多只有包含其中的前n - 1个字符
 5     num_examples = (len(corpus_indices) - 1) // num_steps  # 下取整，得到不重叠情况下的样本个数
 6     example_indices = [i * num_steps for i in range(num_examples)]  # 每个样本的第一个字符在corpus_indices中的下标
 7     random.shuffle(example_indices)
 8 
 9     def _data(i):
10         # 返回从i开始的长为num_steps的序列
11         return corpus_indices[i: i + num_steps]
12     if device is None:
13         device = torch.device('cuda' if torch.cuda.is_available() else 'cpu')
14     
15     for i in range(0, num_examples, batch_size):
16         # 每次选出batch_size个随机样本
17         batch_indices = example_indices[i: i + batch_size]  # 当前batch的各个样本的首字符的下标
18         X = [_data(j) for j in batch_indices]
19         Y = [_data(j + 1) for j in batch_indices]
20         yield torch.tensor(X, device=device), torch.tensor(Y, device=device)

　　测试：

1 my_seq = list(range(30))
2 for X, Y in data_iter_random(my_seq, batch_size=2, num_steps=6):
3     print('X: ', X, '
Y:', Y, '
')

　　相邻采样：

 1 def data_iter_consecutive(corpus_indices, batch_size, num_steps, device=None):
 2     if device is None:
 3         device = torch.device('cuda' if torch.cuda.is_available() else 'cpu')
 4     corpus_len = len(corpus_indices) // batch_size * batch_size  # 保留下来的序列的长度
 5     corpus_indices = corpus_indices[: corpus_len]  # 仅保留前corpus_len个字符
 6     indices = torch.tensor(corpus_indices, device=device)
 7     indices = indices.view(batch_size, -1)  # resize成(batch_size, )
 8     batch_num = (indices.shape[1] - 1) // num_steps
 9     for i in range(batch_num):
10         i = i * num_steps
11         X = indices[:, i: i + num_steps]
12         Y = indices[:, i + 1: i + num_steps + 1]
13         yield X, Y

同样的设置下，打印相邻采样每次读取的小批量样本的输入X和标签Y。相邻的两个随机小批量在原始序列上的位置相毗邻。

1 for X, Y in data_iter_consecutive(my_seq, batch_size=2, num_steps=6):
2     print('X: ', X, '
Y:', Y, '
'

三、循环神经网络基础

知识点记录：

　　循环神经网络：

　　　　目标：

　　　　　　基于循环神经网络实现语言模型，基于当前输入与过去输入的序列，预测序列的下一个字符。

　　　　模型设计思路：

　　　　　　循环神经网络引入一个隐藏变量 H，用 H_t表示H在时间步 t 的值。H_t的计算基于 X_t和 H_t-1，可以认为H_t记录了到当前字符为止的序列信息，利用 H_t对序列的下一个字符进行预测。

　　　　构造：

　　　　　　设X_t ∈ R^n×d 是时间步 t 的小批输入，H_t ∈ R^n×h 是该时间步的隐藏变量，则： H_t = Ø(X_tW_xh + H_t-1W_hh + b_h). 其中，W_xh ∈ R^d×h，W_hh ∈ R^d×h，b_h∈ R¹^×h, Ø 函数是非线性激活函数。因引入 H_t-1W_hh　，H_t 能捕捉截至当前时间步的序列的历史信息，就像是神经网络当前时间步的状态或记忆一样。由于H_t 的计算基于H_t-1 ，上式的计算是循环的，使用循环计算的网络即循环神经网络。在时间步 t ，输出层的输出为： O_t= H_tW_hq + b_q .　其中 W_h'q ∈R^h×q ，b_q ∈ R^1×q 。

　　　　one-hot 向量：　　

　　　　　　将字符表示成向量，假设词典大小是 $N$

$N$ $N$

　　　　　　循环神经网络中较容易出现梯度衰减或梯度爆炸，这会导致网络几乎无法训练。裁剪梯度（clip gradient）是一种应对梯度爆炸的方法。假设我们把所有模型参数的梯度拼接成一个向量 $g$ $min (\frac{θ}{‖ g ‖}, 1) g$

$min (\frac{θ}{‖ g ‖}, 1) g$ $min (\frac{θ}{‖ g ‖}, 1) g$

$min (\frac{θ}{‖ g ‖}, 1) g$ $min (\frac{θ}{‖ g ‖}, 1) g$

$min (\frac{θ}{‖ g ‖}, 1) g$

　　　　模型参数

　　　　　　　　W_xh: 状态-输入权重

　　　　　　　　W_hh: 状态-状态权重

　　　　　　　　W_hq: 状态-输出权重　　　　

　　　　　　　　b_h: 隐藏层的偏置　　

　　　　　　　　b_q: 输出层的偏置

　　　　　　循环神经网络的参数就是上述的三个权重和两个偏置，并且在沿着时间训练（参数的更新），参数的数量没有发生变化，仅仅是上述的参数的值在更新。循环神经网络可以看作是沿着时间维度上的权值共享在卷积神经网络中，一个卷积核通过在特征图上滑动进行卷积，是空间维度的权值共享。在卷积神经网络中通过控制特征图的数量来控制每一层模型的复杂度，而循环神经网络是通过控制W_xh和W_hh中h的维度来控制模型的复杂度。

　　　　一个batch的数据的表示

- - 如何将一个batch的数据转换成时间步数个（批量大小，词典大小）的矩阵？
  - 每个字符都是一个词典大小的向量，每个样本是时间步数个序列，每个batch是批量大小个样本
  - 第一个(批量大小，词典大小)的矩阵：取出一个批量样本中每个序列的第一个字符，并将每个字符展开成词典大小的向量，就形成了第一个时间步所表示的矩阵
  - 第二个(批量大小，词典大小)的矩阵：取出一个批量样本中每个序列的第二个字符，并将每个字符展开成词典大小的向量，就形成了第二个时间步所表示的矩阵
  - 最后就形成了时间步个(批量大小，词典大小)的矩阵，这也就是每个batch最后的形式

　　　　隐藏状态的初始化

　　　　　　　　随机采样时：每次迭代都需要重新初始化隐藏状态（每个epoch有很多词迭代，每次迭代都需要进行初始化，因为对于随机采样的样本中只有一个批量内的数据是连续的）

　　　　　　　　相邻采样时：如果是相邻采样，则说明前后两个batch的数据是连续的，所以在训练每个batch的时候只需要更新一次（也就是说模型在一个epoch中的迭代不需要重新初始化隐藏状态）

$N$

小匠第一周期打卡笔记-Task02

一、文本预处理

二、语言模型

相邻采样

代码实现：

三、循环神经网络基础

知识点记录：

循环神经网络：

目标：

模型参数

　　相邻采样

$n$

　　循环神经网络：

　　　　目标：

　　　　模型参数