由于 Google Cloud Storage 支持对象更改通知，因此它适合丰富插入到存储桶中的对象的良好编程模型，其中服务可以检测该项目并做出相应的反应。这消除了围绕对象更改手动构建通知服务的需要。
但是，假设我们将行级数据（每个数据项，例如用户配置文件名称更改/添加）存储在云存储上，以用户 ID 作为 ID，以实际“名称”作为值，这将导致非常大的数据。桶中小物体的数量。虽然这可以允许系统分析这些数据（例如垃圾邮件检测），但不建议这样做吗？（由于小物体较多）
提前致谢！
使用Apache Beam丰富数据时，对每个数据项都进行一次API调用会不会出错？
（我是 Apache Beam 的新手）
我正在尝试使用Python解释Debezium在Kafka 中存储的Avro记录
{
"name": "id",
"type": {
"type": "bytes",
"scale": 0,
"precision": 64,
"connect.version": 1,
"connect.parameters": {
"scale": "0"
},
"connect.name": "org.apache.kafka.connect.data.Decimal",
"logicalType": "decimal"
}
}
我不确定这对应于哪种 Python 3 原始类型。如何反序列化这个值？
提前致谢！
在分布式处理环境中,通常使用"部分"文件名,例如"part-000",是否可以编写某种扩展名来重命名各个输出文件名(例如每个窗口文件名) Apache Beam？
为此,可能必须能够为窗口指定名称或根据窗口的内容推断文件名.我想知道这种方法是否可行.
至于解决方案应该是流式还是批量式,流式模式示例是优选的
如果您在此处查看:http://cordova.apache.org/docs/en/3.3.0/cordova_storage_storage.md.html#Storage,该页面清楚地显示正在使用的Web SQL数据库API.
此Web SQL数据库API不再像以下所述进行维护:http://dev.w3.org/html5/webdatabase/
此外,并非所有平台都提供适用于Web SQL Database API的PhoneGap解决方案.另一方面,他们还提到支持indexedDB,但是在不同的设备集上.
为什么他们破坏了跨平台规范并且还使用了被弃用的API？
apache-beam ×2
apache-kafka ×1
cordova ×1
debezium ×1
git ×1
git-tag ×1
indexeddb ×1
python ×1
web-sql ×1