使用PaddlePaddle和Ernie模型来计算文本数据的向量表示

2024-04-26 18:28

本文主要是介绍使用PaddlePaddle和Ernie模型来计算文本数据的向量表示,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

import paddle
2from paddlenlp.transformers import ErnieTokenizer, ErnieModel
3import numpy as np
4import json
5
6# 设置PaddlePaddle的全局随机种子
7paddle.seed(1234)
8
9# 初始化分词器
10tokenizer = ErnieTokenizer.from_pretrained('ernie-3.0-tiny-medium-v2-zh')
11
12# 初始化模型
13model = ErnieModel.from_pretrained('ernie-3.0-tiny-medium-v2-zh')
14
15# 确保模型处于评估模式
16model.eval()
17
18# 禁用模型的Dropout层(如果有的话)
19for layer in model.sublayers():
20    if isinstance(layer, paddle.nn.Dropout):
21        layer.train = False
22
23request_body = '{"data":[{"text": "想看销售的统计分析情况 智能销售"}]}'
24request_json = json.loads(request_body)
25texts = [item["text"] for item in request_json["data"]]
26
27# 存储所有句子的嵌入及其对应的原始文本
28sentence_embeddings = []
29sentences = []
30
31# 对每个句子进行循环处理
32for text in texts:
33    # 对句子进行编码
34    encoded_input = tokenizer(text, padding=True, truncation=True, return_tensors='paddle', max_seq_length=512)
35    input_ids = encoded_input['input_ids']
36
37    # 获取模型的隐藏状态输出
38    with paddle.no_grad():  # 不计算梯度,加快计算速度
39        outputs = model(input_ids)
40
41    # 假设我们取每个序列的最后一个隐藏状态作为句子的表示
42    sentence_embedding = outputs[0][0, -1, :]
43    sentence_embeddings.append(sentence_embedding.numpy())
44    sentences.append(text)
45
46# 将每个NumPy数组转换为Python列表
47sentence_embeddings_python_list = [embedding.tolist() for embedding in sentence_embeddings]
48
49# 打印包含所有句子嵌入及对应文本的Python字典
50data_dict = {
51    "sentences": sentences,
52    "vectors": sentence_embeddings_python_list
53}
54print(json.dumps(data_dict, ensure_ascii=False))

使用PaddlePaddle和Ernie模型来计算文本数据的向量表示。整体流程大致正确,但存在一些可以优化的地方。以下是对您的代码进行点评和提出优化建议:

  1. 模型配置:您已经设置了全局随机种子、禁用了Dropout层,并确保模型处于评估模式。这些都是正确的做法。

  2. 处理请求体:您通过json.loads()解析请求体并提取出所有待处理的文本。这部分代码没有问题。

  3. 编码文本

    • 您使用了padding=Truetruncation=True,这会自动对文本进行填充或截断以适应模型的最大长度限制(默认为512)。但是,对于Ernie模型,建议明确指定max_seq_length参数(而不是max_length),以保持与模型预期输入的一致性。
    • 对于return_tensors='pd',应改为return_tensors='paddle',以确保返回的张量类型与PaddlePaddle兼容。
  4. 获取句子向量

    • 您选择每个序列的最后一个隐藏状态作为句子的表示。这是常见的做法之一,尤其是对于分类或问答任务。然而,对于语义相似度计算或聚类等任务,可能需要考虑其他方法,如取所有隐藏状态的均值或池化操作(如[CLS] token的隐藏状态)。
  5. 向量转换与输出

    • 将句子向量从NumPy数组转换为Python列表是合理的,以便将结果以JSON格式返回。
    • 在构建最终输出的data_dict时,建议添加一个键(如sentences)存储原始文本,以便用户能够对应地理解每个向量所代表的句子。

--------------------------------------------------------------------------------------------------------------

在深度学习编程中,`model.eval()` 是一个常见的方法调用,用于将神经网络模型切换到评估(evaluation)模式。这个操作通常是针对已经训练好的模型,在进行预测、验证或者测试阶段时进行的。以下是关于 `model.eval()` 的详细说明:

**作用**:
- **关闭 Dropout 和 Batch Normalization 的随机性**:在训练过程中,Dropout 层和 Batch Normalization 层通常引入随机性以增强模型的泛化能力。Dropout 在每次前向传播时随机丢弃一部分神经元输出,而 Batch Normalization 则依赖于当前 mini-batch 的均值和方差进行标准化。然而,在评估或预测时,我们希望结果是确定性的,不受随机因素影响。因此,切换到评估模式后,Dropout 层会保留所有神经元输出(相当于 dropout rate 设置为 0),Batch Normalization 层则使用整个训练集统计的均值和方差(或在没有足够训练数据时使用移动平均值)进行归一化。

- **禁用自动求梯度(autograd)**:在评估模式下,模型不会计算梯度,这意味着反向传播不会发生,从而节省了内存和计算资源。这对于仅涉及前向传播的预测任务尤为重要。

- **改变某些模块的行为**:某些自定义模块可能根据模型的运行模式(train/eval)有不同的行为。例如,某些模型可能会在评估模式下使用不同的激活函数或连接方式。

**使用示例**:

```python
import torch
from your_model_module import YourModel

# 假设已经加载了预训练好的模型参数
model = YourModel(pretrained=True)

# 将模型设置为评估模式
model.eval()

# 现在可以进行预测或评估
with torch.no_grad():  # 可选,进一步禁用自动求梯度以节省资源
    # 假设 inputs 是预处理后的输入数据
    predictions = model(inputs)
```

**注意**:
- 调用 `model.eval()` 不会影响模型的权重参数;它只是改变了模型在前向传播中的行为。
- 为了确保所有的随机性都被消除,通常在 `model.eval()` 之后还会使用 `torch.no_grad()` 上下文管理器来禁用自动求梯度。这一步不是严格必需的,但有助于减少内存占用并提高预测速度,特别是在处理大量数据时。
- 在完成评估或预测任务后,如果需要重新对模型进行训练,应当调用 `model.train()` 将模型恢复到训练模式。

总之,`model.eval()` 是在深度学习代码中切换模型到评估模式的标准操作,旨在确保模型在预测或评估阶段的行为与训练阶段不同,提供确定性结果并优化性能。

------------------------------------------------------------------------------------------------------------

Dropout层是深度学习模型中一种常用的正则化技术,尤其在神经网络中被广泛采用以防止过拟合,提升模型泛化能力。它的主要作用和工作原理可以概括如下:

作用:

  1. 减少神经元之间的共适应性(Co-adaptation):在训练过程中,Dropout层随机“丢弃”(即临时关闭)一部分神经元(通常是一个概率p,如0.5),使得每次前向传播时,网络结构都会有所变化。这样,每个神经元就不能过度依赖于其他特定神经元的存在,而是需要学会独立地提取有用的特征。这有助于避免模型对训练数据中的特定特征组合形成过于复杂的依赖关系,从而降低过拟合的风险。

  2. 模拟集成学习的效果:Dropout在某种程度上可以被视为一种“随机子网络”的集成。每次前向传播时,由于部分神经元被随机关闭,相当于训练了一个不同的网络结构。在测试阶段,虽然所有神经元都会参与预测,但其权重是在多个随机稀疏网络上训练得到的平均效果,类似集成学习中的投票或平均策略,增强了模型的泛化性能。

  3. 简化学习目标:Dropout通过引入随机噪声,使神经网络在训练时面临更复杂、多样化的输入模式,迫使网络学习更稳健、更通用的特征表示。这种噪声可以看作是一种正则化项,帮助模型在没有显式正则化惩罚(如L1、L2正则化)的情况下,也能实现对模型复杂度的有效控制。

工作原理: 在Dropout层中,每个神经元被保留的概率为p(通常设置为0.5或相近值),被丢弃的概率为1-p。具体操作如下:

  • 在前向传播阶段,对于每一个批次的输入,Dropout层按照设定的概率p,对上一层神经元的输出进行随机二值化。也就是说,对于每个神经元,以概率p将其输出值置为0(相当于暂时丢弃),以概率1-p保持原值不变。
  • 为了保持输出的期望值不变(即不改变网络的整体激活水平),通常会对保留下来的神经元输出进行缩放,乘以一个系数1/p。这样,在大量样本训练的平均意义上,即使部分神经元被丢弃,整个网络的输出分布仍能保持一致。

使用注意事项:

  • 训练与测试阶段的差异:在训练期间启用Dropout,而在测试或推断阶段通常会关闭Dropout。测试时,所有神经元都参与预测,但其权重通常会被调整(乘以p),以近似在Dropout开启时的期望输出。
  • Dropout比例的选择:Dropout比例p的选择通常依赖于模型和任务的具体情况。过高的比例可能导致模型难以学习到有用的特征,而过低的比例可能无法有效抑制过拟合。常见的选择范围在0.1到0.5之间。
  • 与其他正则化技术结合:Dropout常与其他正则化方法(如权重衰减、批归一化等)一起使用,共同提升模型的泛化能力。

综上所述,Dropout层通过随机丢弃神经元的方式,有效地减少了神经网络对训练数据中特定模式的过度依赖,提高了模型的泛化能力和鲁棒性。它是深度学习模型防止过拟合、提升性能的一种重要工具。

-------------------------------------------------------------

这段代码使用了飞桨(PaddlePaddle)深度学习框架,对编码后的输入数据进行转换并创建一个 `paddle.Tensor` 对象。具体解释如下:

1. **`encoded_input['input_ids']`**:
   这部分通常表示已经经过某个预处理或编码过程得到的输入数据。在自然语言处理(NLP)任务中,特别是使用预训练模型(如BERT、GPT等)时,`input_ids` 通常代表了输入文本经词嵌入(Tokenization)后的整数序列。每个整数代表了词汇表中对应词(token)的唯一标识符。`encoded_input` 可能是一个字典结构,其中包含了除 `input_ids` 之外的其他编码信息,如 `attention_mask`、`token_type_ids` 等,具体取决于所使用的模型和编码器。

2. **`paddle.to_tensor(...)`**:
   `paddle.to_tensor()` 是飞桨(PaddlePaddle)提供的一个函数,用于将给定的数据转换为 `paddle.Tensor` 类型。`paddle.Tensor` 是飞桨框架中用于存储和操作数值型数据的基本数据结构,类似于 TensorFlow 中的 `tf.Tensor` 或 PyTorch 中的 `torch.Tensor`。

   函数的参数说明:
   - `encoded_input['input_ids']`: 要转换的数据,这里是一个整数列表或数组,代表了输入文本的编码结果。
   - `dtype='int64'`: 指定转换后的张量数据类型为 64 位整数(`int64`)。这是根据预训练模型通常期望的输入类型指定的,确保与模型兼容。

执行这段代码后,`input_ids` 变量将被赋值为一个 `paddle.Tensor` 对象,其中包含了编码后的输入文本数据,且数据类型为 `int64`。接下来,这个 `input_ids` 张量可以直接作为输入传递给预训练模型进行进一步的处理和计算。例如:

```python
# 假设 model 是已经加载的飞桨预训练模型
model_output = model(input_ids)
```

综上所述,这段代码完成了将编码后的输入文本数据转换为飞桨(PaddlePaddle)框架所需的 `paddle.Tensor` 格式,并指定了数据类型为 `int64`,为后续使用预训练模型进行推理或训练做好准备。

---------------------------------------------------------------------------------------------------------

这段代码提取了一个预训练语言模型(如BERT、RoBERTa等)的输出中的特定向量,作为输入句子的固定长度向量表示(sentence embedding)。具体解释如下:

  1. last_hidden_state: 这是一个通常由预训练语言模型的前向传播函数返回的张量,表示模型对输入序列的所有词(tokens)的隐藏状态。last_hidden_state 的形状通常为 (batch_size, sequence_length, hidden_size),其中:

    • batch_size:批处理中包含的样本数量。
    • sequence_length:输入序列(每个样本)的长度,即词(tokens)的数量。
    • hidden_size:模型的隐藏层维度,即每个词(token)的隐藏状态向量的长度。
  2. last_hidden_state[0, -1, :]: 这段代码使用切片操作从 last_hidden_state 张量中提取特定元素:

    • 0: 在第一个维度(batch_size)上选取第0个样本。如果只有一个样本,则提取该样本的隐藏状态;如果有多个样本,此处仅关注第一个样本的表示。
    • -1: 在第二个维度(sequence_length)上选取最后一个词(token)的隐藏状态。在许多预训练模型中,最后一个词(token)的隐藏状态(通常是 [CLS] 或 [SEP] token 的隐藏状态)被用作整个输入序列的聚合表示,即 sentence embedding。
    • :: 在第三个维度(hidden_size)上选取所有元素,即获取该词(token)完整的隐藏状态向量。

    经过上述切片操作,last_hidden_state[0, -1, :] 将得到一个形状为 (hidden_size,) 的向量,代表了输入句子的固定长度向量表示(sentence embedding)。

总结来说,这段代码从预训练语言模型的输出 last_hidden_state 中提取了首个样本的最后一个词(token)的隐藏状态向量,作为该样本(即输入句子)的 sentence embedding。这个向量可以用于后续的文本相似度计算、分类、聚类等任务。需要注意的是,提取 sentence embedding 的具体方式可能会因模型结构和应用场景的不同而有所变化,上述操作是基于常见的做法进行的解释。

在代码中使用最后一个词(token)的隐藏状态作为句子嵌入,主要是基于许多预训练语言模型(如BERT、RoBERTa、XLNet等)的设计特点和实践中的有效性。以下几点解释了这一做法的原因:

  1. 预训练任务与特殊分隔符: 许多预训练模型在训练过程中采用了特定的自监督学习任务,如BERT的Masked Language Modeling (MLM) 和 Next Sentence Prediction (NSP)。为了适应这些任务,模型的输入序列通常会被添加特殊分隔符:

    • [CLS] (Classification) Token:位于序列的起始位置,用于表征整个序列的全局信息,常用于下游任务(如文本分类、文本匹配)的分类头。
    • [SEP] (Separator) Token:用于分隔序列中的不同部分(如两个句子),在某些模型(如BERT)的NSP任务中,[SEP] 后的隐藏状态可能用于判断两个句子是否连贯。

    在许多情况下,模型在设计时就考虑了这些特殊分隔符的用途。例如,[CLS] 的隐藏状态通常被用作整个序列的聚合表示,即句子嵌入。在您的代码中,如果最后一个词恰好是 '[CLS]',那么提取它的隐藏状态作为句子嵌入是符合模型设计意图的。

  2. 实践中的有效性: 尽管理论上有多种方法可以提取句子嵌入(如平均所有词的隐藏状态、使用Pooling层等),但在实践中,直接使用最后一个词(尤其是 '[CLS]')的隐藏状态作为句子嵌入被证明在许多下游任务中表现良好。这可能是因为特殊分隔符的隐藏状态在训练过程中已经被训练得能够捕获序列的整体信息,尤其是在预训练任务中被直接用于分类或判断的情况下。

  3. 简便性和一致性: 使用最后一个词的隐藏状态作为句子嵌入是一种简便且一致的做法。它无需额外的计算(如平均池化),并且对于所有输入序列,提取句子嵌入的方式都是相同的。这简化了代码实现,并且在处理不同长度的句子时保持了一致性。

综上所述,代码中使用最后一个词(特别是当它是特殊分隔符如 '[CLS]' 时)的隐藏状态作为句子嵌入,是基于预训练模型的设计特点、实践中的有效性以及简便性和一致性考虑。当然,这并非唯一可行的方法,具体选择应根据模型特点、任务需求以及实验效果进行调整。如果您提供预训练模型的具体信息,我可以给出更针对性的建议。

-------------------------------------------------------------------------------------------------------

您提供的代码片段展示了如何使用预训练语言模型(如BERT、RoBERTa等)来计算一组文本句子的词向量(或称为句子嵌入)。总体来说,这段代码遵循了以下常规步骤:

  1. 解析JSON请求体:将请求体字符串转化为Python字典对象,提取出包含文本数据的部分。
  2. 文本预处理:遍历请求体中的每个文本项,使用预定义的tokenizer对文本进行编码,添加填充(padding)和截断(truncation)以保持固定长度,并将结果转换为PaddlePaddle所需的张量格式。
  3. 模型推理:将编码后的输入喂入预训练模型,计算模型的输出。由于只关心模型的隐藏状态(last_hidden_state),所以在计算过程中禁用梯度计算以提高效率。
  4. 提取句子嵌入:从模型输出的最后一个隐藏层中选取每个序列的最后一个隐藏状态作为该句子的表示(sentence embedding)。
  5. 结果转换:将得到的PaddlePaddle张量(paddle.Tensor)转换为NumPy数组,再进一步转换为Python列表,便于后续处理或返回给客户端。

虽然这段代码实现了文本句子到词向量的转换,但存在一些混淆和可能的改进之处。下面是对代码的澄清和优化建议:

澄清

  • 词向量 vs. 句子嵌入:您提到的“词向量”实际上在代码中指的是“句子嵌入”,即整个句子的固定长度向量表示。词向量通常指的是单个词(token)的向量表示,而非整个句子。代码中提取的是每个句子的最后一个词(token)的隐藏状态作为句子嵌入,这在许多预训练模型中是一种常见的做法,但并非唯一方法。其他提取句子嵌入的方法包括平均所有词(token)的隐藏状态、使用Pooling层(如Max Pooling、Mean Pooling)等。

优化建议

  • 提取句子嵌入的方式:如前所述,代码中使用最后一个词(token)的隐藏状态作为句子嵌入。这在很多情况下是合理的,尤其是在使用了特殊分隔符(如 [CLS] 或 [SEP])的预训练模型中,这些分隔符的隐藏状态通常被设计为整个序列的聚合表示。但是,如果模型没有这样的特殊分隔符,或者您希望尝试不同的句子嵌入提取方法(如平均所有词的隐藏状态),则需要相应调整代码。

  • 批量处理:目前的代码对每个句子独立进行编码和模型推理,这可能导致较低的计算效率,特别是在处理大量文本时。为了提高效率,可以考虑将所有文本合并为一个批次,一次性送入模型计算。这通常需要调整tokenizer的接口调用,使其接受一个包含多个文本的列表作为输入,并返回相应的批量编码结果。

  • 结果转换:尽管将PaddlePaddle张量转换为Python列表有助于简化接口和与其他工具的交互,但如果后续处理仍在PaddlePaddle环境中进行,或者不需要立即返回给客户端,那么保留张量形式(paddle.Tensor)可能更为高效,避免不必要的数据转换开销。

总结

您提供的代码实现了使用预训练语言模型计算一组文本句子的句子嵌入(而非词向量),基本流程符合常规做法。为了进一步优化和适应特定需求,可以考虑调整提取句子嵌入的方式、采用批量处理以及根据实际情况选择是否立即转换为Python列表。如果您能提供更多关于预训练模型的细节(如是否有特殊分隔符、句子嵌入提取的特定要求等),我可以为您提供更具体的建议。

-------------------------------------------------------------------------------------------------------------

当然可以,以下是您提供的代码每一行的详细解释:

```python
import paddle
from paddlenlp.transformers import ErnieTokenizer, ErnieModel
import numpy as np
import json
```
- 导入所需库:
  - `paddle`:PaddlePaddle深度学习框架。
  - `paddlenlp.transformers`:PaddleNLP库中的Transformer模块,包含预训练模型和相关工具。
  - `numpy`:用于处理多维数组的Python库。
  - `json`:用于序列化和反序列化JSON数据。

```python
# 设置PaddlePaddle的全局随机种子
paddle.seed(1234)
```
- 设定PaddlePaddle的全局随机种子为1234,确保实验可复现性。

```python
# 初始化分词器
tokenizer = ErnieTokenizer.from_pretrained('ernie-3.0-tiny-medium-v2-zh')
```
- 使用`ErnieTokenizer.from_pretrained()`创建一个基于预训练模型“ernie-3.0-tiny-medium-v2-zh”的分词器实例,用于对文本进行编码。

```python
# 初始化模型
model = ErnieModel.from_pretrained('ernie-3.0-tiny-medium-v2-zh')
```
- 使用`ErnieModel.from_pretrained()`创建一个基于预训练模型“ernie-3.0-tiny-medium-v2-zh”的模型实例。

```python
# 确保模型处于评估模式
model.eval()
```
- 将模型设置为评估模式,这意味着模型不会在前向传播过程中积累梯度,适用于推断任务。

```python
# 禁用模型的Dropout层(如果有的话)
for layer in model.sublayers():
    if isinstance(layer, paddle.nn.Dropout):
        layer.train = False
```
- 遍历模型的所有子层,检查是否为`paddle.nn.Dropout`类型。如果是,则将其训练模式设为`False`,即在当前评估阶段禁用Dropout层。

```python
request_body = '{"data":[{"text": "想看销售的统计分析情况 智能销售"}]}'
request_json = json.loads(request_body)
texts = [item["text"] for item in request_json["data"]]
```
- 定义一个JSON格式的请求体字符串`request_body`,表示要处理的文本数据。
- 使用`json.loads()`将JSON字符串解析为Python字典`request_json`。
- 使用列表推导式从`request_json["data"]`中提取出所有文本,存储在列表`texts`中。

```python
# 存储所有句子的嵌入及其对应的原始文本
sentence_embeddings = []
sentences = []
```
- 创建两个空列表,分别用于存储所有句子的嵌入(向量表示)和对应的原始文本。

```python
# 对每个句子进行循环处理
for text in texts:
    # 对句子进行编码
    encoded_input = tokenizer(text, padding=True, truncation=True, return_tensors='paddle', max_seq_length=512)
    input_ids = encoded_input['input_ids']
```
- 对`texts`列表中的每个句子进行循环处理。
- 调用分词器`tokenizer`对当前句子进行编码,设置参数:
  - `padding=True`:不足最大长度的部分填充。
  - `truncation=True`:超过最大长度的部分截断。
  - `return_tensors='paddle'`:返回PaddlePaddle张量。
  - `max_seq_length=512`:最大序列长度限制。
- 从编码结果中提取出`input_ids`,即经过编码的文本对应的token索引序列。

```python
    # 获取模型的隐藏状态输出
    with paddle.no_grad():  # 不计算梯度,加快计算速度
        outputs = model(input_ids)
```
- 使用`with paddle.no_grad():`上下文管理器,确保在模型前向传播过程中不计算梯度,提高计算效率。
- 调用模型`model`对`input_ids`进行前向传播,得到输出`outputs`。

```python
    # 假设我们取每个序列的最后一个隐藏状态作为句子的表示
    sentence_embedding = outputs[0][0, -1, :]
    sentence_embeddings.append(sentence_embedding.numpy())
    sentences.append(text)
```
- 从模型输出`outputs[0]`中取出最后一个隐藏状态(假设其为句子的向量表示),并存储在变量`sentence_embedding`中。
- 将`sentence_embedding`从PaddlePaddle张量转换为NumPy数组,并添加到`sentence_embeddings`列表中。
- 将当前处理的原始文本`text`添加到`sentences`列表中。

```python
# 将每个NumPy数组转换为Python列表
sentence_embeddings_python_list = [embedding.tolist() for embedding in sentence_embeddings]
```
- 使用列表推导式将`sentence_embeddings`中的每个NumPy数组转换为Python列表,并存储在`sentence_embeddings_python_list`中。

```python
# 打印包含所有句子嵌入及对应文本的Python字典
data_dict = {
    "sentences": sentences,
    "vectors": sentence_embeddings_python_list
}
print(json.dumps(data_dict, ensure_ascii=False))
```
- 构建一个字典`data_dict`,包含键`sentences`(存储原始文本)和`vectors`(存储向量表示)。
- 使用`json.dumps()`将`data_dict`转换为JSON格式的字符串,并打印出来,同时设置`ensure_ascii=False`以保留中文字符。

--------------------------------------------

这篇关于使用PaddlePaddle和Ernie模型来计算文本数据的向量表示的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/938324

相关文章

大模型研发全揭秘:客服工单数据标注的完整攻略

在人工智能(AI)领域,数据标注是模型训练过程中至关重要的一步。无论你是新手还是有经验的从业者,掌握数据标注的技术细节和常见问题的解决方案都能为你的AI项目增添不少价值。在电信运营商的客服系统中,工单数据是客户问题和解决方案的重要记录。通过对这些工单数据进行有效标注,不仅能够帮助提升客服自动化系统的智能化水平,还能优化客户服务流程,提高客户满意度。本文将详细介绍如何在电信运营商客服工单的背景下进行

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后,随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步,我们目前的解决方案是建立数据中间表。把需要检索的业务数据,统一放到一张M

关于数据埋点,你需要了解这些基本知识

产品汪每天都在和数据打交道,你知道数据来自哪里吗? 移动app端内的用户行为数据大多来自埋点,了解一些埋点知识,能和数据分析师、技术侃大山,参与到前期的数据采集,更重要是让最终的埋点数据能为我所用,否则可怜巴巴等上几个月是常有的事。   埋点类型 根据埋点方式,可以区分为: 手动埋点半自动埋点全自动埋点 秉承“任何事物都有两面性”的道理:自动程度高的,能解决通用统计,便于统一化管理,但个性化定

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

异构存储(冷热数据分离)

异构存储主要解决不同的数据,存储在不同类型的硬盘中,达到最佳性能的问题。 异构存储Shell操作 (1)查看当前有哪些存储策略可以用 [lytfly@hadoop102 hadoop-3.1.4]$ hdfs storagepolicies -listPolicies (2)为指定路径(数据存储目录)设置指定的存储策略 hdfs storagepolicies -setStoragePo

Hadoop集群数据均衡之磁盘间数据均衡

生产环境,由于硬盘空间不足,往往需要增加一块硬盘。刚加载的硬盘没有数据时,可以执行磁盘数据均衡命令。(Hadoop3.x新特性) plan后面带的节点的名字必须是已经存在的,并且是需要均衡的节点。 如果节点不存在,会报如下错误: 如果节点只有一个硬盘的话,不会创建均衡计划: (1)生成均衡计划 hdfs diskbalancer -plan hadoop102 (2)执行均衡计划 hd

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

使用opencv优化图片(画面变清晰)

文章目录 需求影响照片清晰度的因素 实现降噪测试代码 锐化空间锐化Unsharp Masking频率域锐化对比测试 对比度增强常用算法对比测试 需求 对图像进行优化,使其看起来更清晰,同时保持尺寸不变,通常涉及到图像处理技术如锐化、降噪、对比度增强等 影响照片清晰度的因素 影响照片清晰度的因素有很多,主要可以从以下几个方面来分析 1. 拍摄设备 相机传感器:相机传