Library Search
结果页生产者与消费者基础示例
在 知识库 中找到 8 个匹配结果。
知识库
知识库
8 个 01-pyplot-basics # ============================================================
# 5. 饼图（Pie Chart）
# ============================================================
labels = ["工程部", "销售部", "市场部", "HR", "财务"]
sizes = [35,… 2% 01-keras-sequential-mnist # ============================================================
# 7. 预测
# ============================================================
predictions = model.predict(x_test[:5])
pred_classes = np.argmax(p… 2% 生产者与消费者基础示例 # Kafka 生产者与消费者 - Python (kafka-python)
## 目标
演示 Kafka 的 Producer 和 Consumer 基本用法，包含分区和消费者组概念。
## 环境准备
```bash
pip install kafka-python
# 确保 Kafka 已启动并创建了 test-topic
```
## 完整代码
### 生产者（producer.p… 2% Hello World - 消息发送与接收 print('[*] Waiting for messages. Press CTRL+C to exit.')
channel.start_consuming()
```
## 运行步骤
```bash
# 终端1：启动消费者
python consumer.py
# 终端2：发送消息
python producer.py
```
## 预期输出
- 生产者终端：`[x] Sent 'He… 2% 入门教程 - 高吞吐流处理核心概念 Kafka 通过以下机制实现 EOS：
- **幂等生产者**：`enable.idempotence=true`
- **事务**：`producer.init_transactions()` + `producer.commit_transaction()`
- **消费者隔离级别**：`isolation.level=read_committed`
## 5. Kafka Streams… 2% MN316 NB-IoT驱动代码 — STM32 UART+DMA+IDLE · MQTT物模型上报 /* ---- 构造Topic ---- */
char topic[100];
snprintf(topic, sizeof(topic), ONENET_TOPIC_PROP_POST,
s_cfg.product_id, s_cfg.device_name);
/* ---- MQTT发布 (hex编码) ---- */
char… 2% 02-neural-network-mnist | 概念 | 说明 |
|------|------|
| `nn.Module` | 所有神经网络层的基类，定义 `forward()` |
| `DataLoader` | 自动批处理、打乱、多线程加载 |
| `transforms.Compose` | 数据预处理流水线 |
| `optimizer.zero_grad()` | **必须！** 否则梯度会累积 |
| `model.tra… 2% 01-array-basics | 概念 | 说明 |
|------|------|
| `ndarray` | 同构多维数组，所有元素类型相同 |
| `shape` | 元组，描述各维度大小 |
| `dtype` | 数据类型，如 float64、int32 |
| 向量化 | 一次操作作用于整个数组，底层 C 实现 |
| 广播 | 不同形状数组的自动对齐运算 |
| `axis=0` | 沿行方向（对列操作），结果减… 2%