首先RNN(Recurrent Neural Networks)在处理长序列长有很强的优势,加上近来前向反馈算法的成功,导致RNN在长文本上得到了很好的应用。

\"\"

简单来说RNN神经网络能够记住长序列中的某种特征,因此可以很好处理时序信息,比如文本。

首先你需要训练样本,我通过网上搜集40000多首的唐诗,他们大概这个样子。

\"\"

首先我们需要进行汉字的 ding, ding的研究已经取得了很大的进展,在这里我们只是简单地进行处理,简单来说我统统计所有汉字的词频,然后按照词频从高到低进行排序,这样我就获得了每个汉字和一个列表序号的映射关系。

poetry_file =\'poetry.txt\'

# 诗集
poetrys = []
with open(poetry_file, \"r\", encoding=\'utf-8\') as f:
#with open(poetry_file, \"r\") as f:
#with codecs.open(poetry_file, \"r\", \'utf-8\') as f:
	for line in f:
		try:
			 , content = line.strip().split(\':\')
			content = content.replace(\' \', \'\')
			if \'_\' in content or \'(\' in content or \'(\' in content or \'《\' in content or \'[\' in content:
				continue
			if len(content) < 5 or len(content) > 79:
				continue
			content = \'[\' + content + \']\'
			poetrys.append(content)
		except Exception as e:
			pass

# 按诗的字数排序
poetrys = sorted(poetrys,key=lambda line: len(line))
print(\'唐诗总数: \', len(poetrys))

# 统计每个字出现次数
all_words = []
for poetry in poetrys:
	all_words += [word for word in poetry]
counter = collections.Counter(all_words)
count_pairs = sorted(counter.items(), key=lambda x: -x[1])
words, _ = zip(*count_pairs)

# 取前多少个常用字
words = words[:len(words)] + (\' \',)
# 每个字映射为一个数字ID
word_num_map = dict(zip(words, range(len(words))))
# 把诗转换为向量形式,参考TensorFlow练习1
to_num = lambda word: word_num_map.get(word, len(words))
poetrys_vector = [ list(map(to_num, poetry)) for poetry in poetrys] 

通过了 ding我们就可以将每一首诗会转化为一个多维向量,维度的个数代表汉字的个数。

我们利用rnn神经网络对每一首诗进行训练,RNN的神经网络的搭建现在都比较固定了。具体可以参考Google的Tensorflow的官方文档。

def neural_network(model=\'lstm\', rnn_size=128, num_ s=2):
	if model == \'rnn\':
		cell_fun = tf.nn.rnn_cell.BasicRNNCell
		#cell_fun = tf.contrib.rnn.BasicRNNCell
	elif model == \'gru\':
		cell_fun = tf.nn.rnn_cell.GRUCell
	elif model == \'lstm\':
		#cell_fun = tf.nn.rnn_cell.BasicLSTMCell
		cell_fun = tf.nn.rnn_cell.BasicLSTMCell
        #tf.contrib.rnn.BasicRNNCell
	cell = cell_fun(rnn_size, state_is_tuple=True)
	cell = tf.nn.rnn_cell.MultiRNNCell([cell] * num_ s, state_is_tuple=True)
	initial_state = cell.zero_state(batch_size, tf.float32)

	with tf.variable_scope(\'rnnlm\'):
		softmax_w = tf.get_variable(\"softmax_w\", [rnn_size, len(words)+1])
		softmax_b = tf.get_variable(\"softmax_b\", [len(words)+1])
		with tf.device(\'/gpu:0\'):
			 ding = tf.get_variable(\" ding\", [len(words)+1, rnn_size])
			inputs = tf.nn. ding_lookup( ding, input_data)

	outputs, last_state = tf.nn.dynamic_rnn(cell, inputs, initial_state=initial_state, scope=\'rnnlm\')
	output = tf.reshape(outputs,[-1, rnn_size])

	logits = tf.matmul(output, softmax_w) + softmax_b
	probs = tf.nn.softmax(logits)
	return logits, last_state, probs, cell, initial_state

 

搭建好神经网络之后我们就可以进行训练了,我们采用分批训练,每64首训练一次。

 

def train_neural_network():
	logits, last_state, _, _, _ = neural_network()
	targets = tf.reshape(output_targets, [-1])
	loss = tf.contrib.legacy_seq2seq.sequence_loss_by_example([logits], [targets], [tf.ones_like(targets, dtype=tf.float32)], len(words))
	cost = tf.reduce_mean(loss)
	learning_rate = tf.Variable(0.0, trainable=False)
	tvars = tf.trainable_variables()
	grads, _ = tf.clip_by_global_norm(tf.gradients(cost, tvars), 5)
	optimizer = tf.train.AdamOptimizer(learning_rate)
	train_op = optimizer.apply_gradients(zip(grads, tvars))

	with tf.Session(config=config) as sess:
		sess.run(tf.global_variables_initializer())
		saver = tf.train.Saver(tf.all_variables())

		for epoch in range(50):
			sess.run(tf.assign(learning_rate, 0.002 * (0.97 ** epoch)))
			n = 0
			for batche in range(n_chunk):
				train_loss, _ , _ = sess.run([cost, last_state, train_op], feed_dict={input_data: x_batches[n], output_targets: y_batches[n]})
				n += 1
				print(epoch, batche, train_loss)
			if epoch % 7 == 0:
				saver.save(sess, \'./train_dir/poetry.ckpt\', global_step=epoch)

我们训练结束后保存模型。

我们下次直接使用这个模型,采用随机开始,这样每次都生成不同的诗。当然这里涉及到了停止的问题,我会在每一首诗的后面加一个截断符,这样网络就会学习到这样的特征。

def gen_poetry():
	def to_word(weights):
		t = np.cumsum(weights)
		s = np.sum(weights)
		sample = int(np.searchsorted(t, np.random.rand(1)*s))
		return words[sample]

	_, last_state, probs, cell, initial_state = neural_network()
	result = \"\"

	with tf.Session() as sess:
		sess.run(tf.global_variables_initializer())

		saver = tf.train.Saver(tf.all_variables())

		module_file = tf.train.latest_checkpoint(\'./train_dir\')
		print(module_file)
		saver.restore(sess, module_file)

		state_ = sess.run(cell.zero_state(1, tf.float32))

		x = np.array([list(map(word_num_map.get, \'[\'))])
		[probs_, state_] = sess.run([probs, last_state], feed_dict={input_data: x, initial_state: state_})
		word = to_word(probs_)
		#word = words[np.argmax(probs_)]
		poem = \'\'
		while word != \']\':
			poem += word
			x = np.zeros((1, 1))
			x[0, 0] = word_num_map[word]
			[probs_, state_] = sess.run([probs, last_state], feed_dict={input_data: x, initial_state: state_})
			word = to_word(probs_)
			#word = words[np.argmax(probs_)]
		result = poem
	return result

运行结果如下:

\"\"

挑选了几首诗如下:

poetry1:东远春生梦,浮波奔浩氛。光繁空井碧,池辈正无尘。茗牖藏田畔,云霞有瑞香。烟波阻此去,风景向秦关。枕外无多迹,临朝半镜明。谁怜竹洞里,终可遣忘衡。

poetry2:行深复何路,异客动郊山。又失天涯外,孤舟行处稀。共知缘卫渡,又上故乡情。月有妆斋满,野心迎夕天。塞风冈自入,谷口和踪息。修菊倍傍人,结人难相慰,还是若云栖。

poetry3:莫讶翼憧鞬事,至杨初驻袖中筵。轻竿留戴黄蓑楫,惨淡时将六队声。晴落彩云依郭处,恶云移以赋行人。那堪数曲回车职,更见纤尘亦恐眠。

github:https://github.com/danzhewuju

收藏 打印