我正在尝试将多行插入到pyspark中的dataframe。这是我的代码：import pydocumentdbfrom pydocumentdb importclient = document_client.DocumentClient(host,{'masterKey': masterKey}, connectionPolicy)
然后我定义了一个数据库和一个集
浏览 19提问于2018-09-03得票数 0
我有一个将json文件转储到Azure存储Blobs中的进程。我正在使用Azure数据工厂将blobs向上插入到Azure CosmosDB。一旦json被插入到CosmosDB中，我希望将其从存储中删除。
我可以将Delete操作添加到工作流中，但这样做可能会删除尚未处理的json文件。
浏览 23提问于2021-10-27得票数 0
我正在尝试执行从CosmosDB API到数据库的MongoDB的读/写流数据，java.lang.UnsupportedOperationException:数据源mongodb不支持微批处理。from pyspark.streaming import StreamingContext frompyspark.sql.functions
浏览 12提问于2022-10-06得票数 0
下面的存储库类从批处理中将数据插入到CosmosDb数据库中：{ }}
不幸的是，zonierList中有超过30000个元素，它在
浏览 0提问于2019-03-20得票数 0
回答已采纳
我正在调查使用CosmosDB (以前的DocumentDB)，我们目前使用MongoDB，所以我尝试使用MongoAPI for CosmosDB。我在azure中创建了一个CosmosDB部署，创建了一个集合，并指定了一个"/rateId“分区键。据我从了解到，这个分区键应该与我插入的每个文档中的一个属性相关，因此我试图插入一个基本文档，如下所示： "rateId&quo
浏览 11提问于2017-08-09得票数 11
回答已采纳
3回答
从火花错误插入到CosmosDB
、、、、
我对Spark/CosmosDB/Python非常陌生，所以我正在研究MS站点和GitHub的代码示例，同时尝试自己创建一些东西。经过与Spark连接器的长期斗争，我能够从CosmosDB收集中读取数据.现在，我想做相反的(插入)，但发现了另一个障碍。下面是我要介绍的示例：。
我能够从宇宙阅读，并做一些数据，但我不能插入回宇宙。快速搜索后，我尝试将模式(“追加”)添加到我的最后一
浏览 7提问于2018-04-05得票数 4
我想知道我们是否可以在同一连接上检索由CosmosDb(mongoDb)创建的最新插入的_id(ObjectId)。(类似于sql server中的SCOPE_IDENTITY() )。我正在使用CosmosDb输出绑定从azure函数插入文档。
浏览 4提问于2018-07-26得票数 0
3回答
无法通过星火连接到Mongo
、、、、
我正在尝试通过Apache主程序读取Mongo的数据。我用了三台机器
_sparkSession = SparkSession.builder.master(masterPath).appName(appName)\\
.config("spark.mongodb.output.uri",
浏览 16提问于2017-07-17得票数 3
回答已采纳
我正在开发简单的node.js代码，通过使用http触发函数，通过Azure函数app将新文档插入到cosmosDB中。这只是从http的参数中获得输入值并输出到cosmosDB(SQL )。大约在过去的两周，它成功地运行了，但现在面临着内部服务器错误。怪不得?对azure函数的运行时次要版本更新有影响吗？"direction": "in",
"name": &q
浏览 2提问于2018-06-27得票数 1
我正在使用Azure Data Factory将数据从Azure data Lake Store复制到Cosmos DB中的集合。我们将在数据湖中有几千个JSON文件，每个JSON文件大约。3 GB。我正在使用数据工厂的复制活动，在初始运行中，一个文件需要3.5h才能加载，收集组设置为10000 RU/s，数据工厂使用默认设置。现在我已经将其扩展到50000 RU/s，将cloudDataMovementUnits设置为32，将writeBatchSize设置为10，看看是否提高了速度
浏览 0提问于2017-08-09得票数 2
1回答
在Azure环境中，我有一个Azure SQL Db和一个CosmosDb Graph。使用Azure Data Factory，我需要将数据从Sql插入/更新到GraphDb。我的想法是，首先需要将数据转换为json，然后将其插入到GraphDb中。这是要走的路吗？还有别的办法吗？
谢谢。
浏览 13提问于2019-10-25得票数 3
回答已采纳
我试图使用sproc通过Python将文档批量插入到CosmosDB中。我正在用这里建议的sproc进行测试
{"id":"Hello1"}，{"id":"Hello2"}异常= SyntaxError: JSON.parse错误:位置为2的</
浏览 0提问于2018-06-25得票数 0
回答已采纳
我正在使用自定义的azure函数处理程序(使用两条路由从cosmosdb(关于插入)和一个计时器进行POST触发器)。
它们只在本地启动函数时执行一次。这是预期的行为吗？我期望这个函数每次都在DB插入上运行。
浏览 3提问于2022-06-01得票数 0
我希望只将更改后的数据从CosmosDB移动到Storage account，就像只有修改或插入的更改数据才能被移动一样。如何在cosmosDB中执行更改提要过程？。
请分享这个链接。
浏览 2提问于2021-08-06得票数 1
每个car的唯一性在Car对象中由一些值表示，这将是常规rdbms设置中唯一键的基础。我有一个Azure函数，当文件上传到blob存储时解析它，并将解析的数据插入到CosmosDB中。但是，随着时间的推移，这种插入只会使数据库中的</
浏览 1提问于2018-04-18得票数 1
回答已采纳
我尝试做的是，每当从集合中删除文档时，我希望将删除的记录插入到单独的集合中。我想要触发一个操作，在实际删除发生之前将要删除的记录插入到备份集合中。我找到了关
浏览 1提问于2020-06-10得票数 0
使用最新的蔚蓝cli (2.0.21)，我试图使用以下脚本(来自powershell)在CosmosDB中创建一个切分的MongoDB集合：
从C#库中插入带有MongoB.Drivers nuget包的文档也失败，得到错误：显然我的文档包含了shard键属性"TaskId&
浏览 0提问于2017-12-01得票数 3
3回答
我正在编写一个与Azure Cosmos DB交互的应用程序。我需要在一个会话中提交30,000个记录到CosmosDB。因为我使用的是.NET内核，所以我不能使用BulkInsert动态链接库。因此，我使用Foreach循环来插入到CosmosDB中。但是我看到每秒太多的请求，并且它超载了CosmosDB对RU的限制。
浏览 60提问于2019-05-15得票数 2
回答已采纳
我正在尝试将一条记录插入Azure CosmosDB表存储中。我创建了一个计时器函数，并将CosmosDB表存储集成到输出中。下面是函数。public string RowKey { get; set; }}
通过将函数与输出绑定集集成为Azure表存储，我尝试了相同的代码它返回状态: 202接受插入行。但是在Azure CosmosDB表存储中，没有插入行，我获得了相同<em
浏览 3提问于2017-10-24得票数 0
回答已采纳
如何从PHP应用程序向CosmosDB (使用SQL )插入数据(文档)？
是否可以处理插入查询？
浏览 1提问于2018-05-25得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
