2回答
我最近开始研究Azure数据资源管理器( Kusto)。
我要求对Kusto表进行动态排序。
//变量声明
let SortColumn ="run_date";
let OrderBy="desc";
//实际守则
tblOleMeasurments column1，column2，column3，run_date SortColumn OrderBy命令
在这里，我的代码运行良好，直到Sortcolumn为止，但是当我试图在OrderBy之后添加SortColumn时，kusto给了我错误。
这里我的要求是从变量OrderB
浏览 7提问于2021-08-06得票数 0
回答已采纳
我在集群中有多个Kusto数据库-每个数据库代表一个连续的集成测试运行。我经常喜欢在多个数据库中搜索，以查看问题发生的范围有多广，或者问题第一次开始发生的时间。
我会这样做：
union (database('2018-08-*').['*InterestingTables']) | where Message has "Danger, Danger, Will Robinson!" | project OccurrenceTime,Message
我得到了一个很好的概述，但没有办法知道每一行来自哪个数据库。消息本身不足以让我知道两个相邻的行是来
浏览 1提问于2018-08-22得票数 2
回答已采纳
2回答
我正在尝试构建一个KUSTO查询，以验证日志是否到达Azure日志分析表。这是我的代码。这个命令可以很好地工作&给出它收到的记录的数量。但问题是它没有在查询输出中考虑接收到零(而不是任何)日志的表名 union withsource=sourceTable kind=outer Table1, Table2, Table3
| summarize AggregatedValue=count() by bin(TimeGenerated, 5m), sourceTable 预期输出： | Table Name | Count |
----------------------
| Tab
浏览 31提问于2020-10-10得票数 0
我正在处理一个场景，在特定时间间隔之后，将创建一个新表。我有一个PowerBI报告，它运行在这个kusto查询上。这个kusto查询应该在创建的最新表上运行。由于表名包含创建日期，I可以找到具有以下查询的最新表名，但是如何在单变量中获取以下查询的输出？这样，我的后续查询就可以选择这个表名来生成报告。
查询：
在.show表中，TableName包含"XXX“\x{e76f}项目TableName，年份=拆分( TableName，"")3，月份= split(TableName，"")4，day = split(TableName，"_"
浏览 3提问于2020-10-20得票数 0
1回答
我有Kusto表的顶点+边，并希望把它们绘制成网络图。
我试过使用Python插件，但是只允许表格输出。
是否有通过/ Kusto的任何方式/黑客方式来做到这一点？
谢谢!
浏览 4提问于2022-08-17得票数 1
1回答
我有一个ADF，它每天将Kusto函数的输出写入Kusto表。我需要每天将数据插入到表中。我没有找到更新Kusto中现有数据的方法。如果数据不存在，是否可以通过ADF插入行，否则更新现有的行？
集合或替换对我来说将是非常昂贵的，因为表由一组巨大的数据组成。
如果这是不可能的，我是否可以使用我拥有的日期时间戳截断过去两个月的数据，并从函数中重新加载它？
浏览 0提问于2019-07-24得票数 4
回答已采纳
1回答
我有一项任务要把仪表板从Splunk转换到Kusto，我看到了由于Splunk在UTC时区有数据表的不同，但是我认为Kusto正在占用我的本地时区。1)是否有一种在Kusto中查询数据以识别当前时区的方法。2)将Kusto表或查询转换为使用UTC时区与Splunk数据匹配。谢谢。
浏览 2提问于2021-10-05得票数 0
回答已采纳
我正在尝试测试我的节点和Azure数据资源管理器(ADX/ Kusto)之间的连接。我正在考虑使用python脚本在Kusto上创建一个表。
请注意，我不太熟悉这其中的任何一个，因此下面的详细步骤。
我在微软文档上跟踪这个。
生成应用程序ID和密钥
使用应用程序注册服务：
创建新的注册(名为kusto test)：
创建客户端秘密：
创建Kusto DB
在集群中，从UI创建一个数据库(称为kusto-test)。
Authorization
在ADX集群上>访问控制(IAM) >添加角色分配。
Python脚本
from azu
浏览 1提问于2019-05-28得票数 2
回答已采纳
我使用一个复制活动从Azure SQL DB源读取数据并将其写入Kusto接收器。
在我的源代码中，名为RawJson的列包含作为nvarchar(max)存储的JSON。
JSON的结构如下所示：
{
"id" : 1,
"text" : "Some text",
"foo" : "bar"
}
我的Kusto表有JSON中所有属性的专用列：Id、Text、Foo。
使用ADF UI，如何指示复制活动将RawJson.text映射到列Text
浏览 1提问于2022-06-01得票数 0
回答已采纳
我正在尝试使用kusto函数中的摄取代码将记录插入到kusto表中。在运行查询时，我看到了以下错误。在kusto函数中有使用摄取的选项吗？ .create function with (docstring = "test ingest") Insertbackups {
.ingest inline into table backup <|
"test", 2, "Succeeded", 1, 2, 1.1, 3, false
} 错误:发生识别错误。令牌：。
浏览 9提问于2021-01-29得票数 0
我正在尝试使用AzureKusto库从R连接到Azure数据资源管理器中的数据库。在此文档之后，调用kusto_database_endpoint(.)函数我需要打开一个浏览器页面并手动插入打印的代码。有一种方法可以跳过这个手动步骤并自动执行吗？还是有连接到ADX db的替代方案？
谢谢你的帮助！
浏览 6提问于2021-12-13得票数 0
我在MySQL中有几个具有不同模式的不同表，但是所有的表都有一个自动递增的ID和一个时间戳(更准确地说，列名是日期时间类型的"create_timestamp“)。
为了给这个问题提供更多的上下文，我正在构建一个社交数据聚合器，而我的MySQL DB只是从社交媒体API中缓存数据。因此，这些表格是为Instagram，Youtube视频，推特等提供的。我的目标是根据它们的create_time，从每种记录的混合中查询总共20条记录。因为每个媒体API返回不同的数据，每个表有一个非常不同的模式。
在伪代码中，我试图做到这一点：
SELECT * FROM instagrams, twee
浏览 8提问于2013-04-06得票数 1
我正在尝试将数据摄取到Azure表中，并使用Python的QueuedIngestClient.ingest_from_dataframe(df，INGESTION_PROPERTIES)，并且没有插入数据。我运行了".show摄入失败“，并显示为"Mapping reference 'SL_Depth_mapping' of type 'mappingReference' in database 'my-db' could not be found."。我在数据库中提供了这个映射，服务主体被赋予了Ingestor角色和A
浏览 3提问于2021-07-13得票数 1
回答已采纳
通过编写以下活动，我将ADF用作将数据从Cosmos写入Kusto数据库的管道：
database.Rename 在Kusto数据库中创建临时表。将数据从cosmos复制到临时表。删除原始表，如果存在于Kusto 临时表中，则删除原始表。
所有这些更改都是我的GIT中JSON文件的一部分。
我在网上看到ADF中的调试过程没有发布更改，所以我无法看到Kusto数据库中的更改(临时表创建、数据复制、旧表删除、临时表重命名)。
如何在ADF中查看管道调试过程中的所有更改并进行验证(验证是否创建了正确的表名，并在临时表中正确转储数据)？
浏览 2提问于2021-06-11得票数 0
回答已采纳
1回答
是否有一种方法来克隆Kusto中的表，使其具有原始表的所有范围？即使不可能保留区段，至少有一种将表复制到新表的表演性方法。我试了以下方法：-
.set new_table <| existing_table;
它一直在运行，并出现超时错误。有什么方法可以让Kusto引擎认识到这只是一个转储拷贝而不是使用Kusto引擎，它只是从后端执行一个简单的blob副本，只需将新表指向复制的blob，从而绕过整个Kusto处理路由？
浏览 2提问于2020-01-17得票数 3
回答已采纳
1回答
在Kusto中传递多个值
、、、
下面的第一个查询(x)返回一个由10个名称组成的列，然后运行另一个查询，以在另一个表中找到这些名称，并返回每一行的输出。我怎么能这么做？我想我需要一个类似的预言：
let x = cluster('xcluster.kusto.windows.net').database('xdatabase').xtable
| limit 10
;
let y = cluster('ycluster.kusto.windows.net').database('ydatabase').ytable
| where Name has strcat
浏览 3提问于2022-06-09得票数 1
回答已采纳
当我试图从Azure管道创建Azure数据资源管理器数据库中的表时，我得到了以下错误。
误差
##errorService返回了一个错误: Error: getaddrinfo ENOTFOUND testdbprod.kusto.windows.net testdbprod.kusto.windows.net:443 server: testdbprod.kusto.windows.net数据库:testprod命令：..create merge表通知(时间戳: datetime，NoteType: string，homename: string，Value: string)
Pipelin
浏览 15提问于2022-11-22得票数 0
我在Azure日志中有以下日志：
以上查询如下：
输出如下所示，看起来像一个‘散点图’，但我正在寻找一个类似于时间图的连接点，但未能做到：
我如何连接这些点，或者是否存在限制，或者上面的KQL (Kusto查询语言)的编写方式？
浏览 14提问于2021-02-27得票数 0
我有一个Excel文件，用于编辑Azure数据资源管理器(Kusto)之外的数据。我将使用哪些Kusto代码在需要时将这些数据摄取到Kusto查询中？
到目前为止，我似乎需要使用：
.create表(名称:类型，名称:类型)
来创建一个表。
如果我的CSV文件存储在OneDrive中，那么填充表的语法是什么？假设文件名为Sample.csv。
浏览 10提问于2020-02-28得票数 0
我想根据kusto表的查询结果创建一个Application insight的警报规则。实际上，我希望对Application Insights上的kusto表运行查询
浏览 20提问于2021-06-08得票数 1
1回答
我们正在将遥测数据摄取到ADX中，表中的一列存储嵌套的JSON，其中每个单元格包含Json的8000+行。
在Kusto explorer中，在查询表数据(例如"take 10“)之后，当我单击嵌套JSON值单元格时，整个Kusto Explorer将进入无响应模式，
接下来，我需要终止会话并始终重新打开。对于这类问题，我们有什么解决方案吗？
浏览 9提问于2021-09-02得票数 0
在运行PowerShell脚本连接到ADX群集数据库时，我遇到了以下错误。
错误：
New-Object: /home/anuruddha/kqltest.ps1:10
Line |
10 | $kcsb = New-Object Kusto.Data.KustoConnectionStringBuilder ($clusterU …
| ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
| Exception calling ".ctor" with "
浏览 14提问于2022-11-21得票数 0
我创建了一个Azure数据资源管理器(ADX)集群和一个表(称为ABC)。这些数据通过ADX中内置的管道进入Kusto表-(通过事件网格从azure blob获取数据)。我还创建了一个JSON摄入映射，使用该映射可以摄取数据。我在输入的数据中有一个字段，它是它的缩写格式。是否有一种方法(可能是Kusto函数或Kusto摄取映射中的某些属性)允许我引用Kusto中的另一个表，其中包含相应的缩写和完整形式，并将完整的单词(而不是缩写的单词)吞到表中？输入的数据是快速的，所以我想繁重的计算是不可行的。
浏览 0提问于2021-06-16得票数 1
回答已采纳
1回答
我最近开始和库斯托合作。我被困在一个用例中，我需要确认我所采用的方法是正确的。
我有以下格式的数据
在上面的例子中，如果状态是1，如果时间框架等于15秒，那么我需要假设它是1出现的。
所以在这种情况下，状态的出现。我的方法是
if the current and next rows status is equal to 1 then take the time difference and do row_cum_sum and break it if the next(STATUS)!=0.
尽管这种方法给出了正确的输出，但我假设一旦增加大小，性能就会下降。
我正在寻找一种替代的方法(如
浏览 5提问于2020-06-09得票数 2
回答已采纳
我正在尝试将在Azure Datalake中找到的csv文件中的数据复制到SQL Server中的表中。作为一个条件，我只想使用数据库表中的文件名列复制数据库中尚未存在的文件。下面是我的尝试(我在互联网上找不到这样的例子)。
我首先使用一个Get Metadata活动来检索数据湖中的所有文件。同时，我使用一个Lookup活动来获取选择表中的不同文件名。第一张图片显示了活动的组织。
以下是Get Metadata和Lookup活动的输出。
Datalake文件元数据输出
{
"childItems": [
{
"n
浏览 3提问于2021-09-13得票数 2
我在Apps中运行了Azure函数应用程序，并且我能够在Metrics中按实例级别获得Http错误的数量(Pls见图)。我想通过Kusto查询获得相同级别的化妆品，并尝试了所有无法找到的日志表。是否有可能通过实例使用Kusto获得这些指标？
我签了AzureMetrics，没有存储任何实例级的数据:下面是用于获取所有Here错误的查询。
AzureMetrics
| where ResourceGroup == "RG"
| where TimeGenerated {TimeRange}
| where ResourceId in ("ResourceId
浏览 4提问于2022-01-21得票数 0
我们可以使用Azure data Explorer python SDK在Python脚本中使用purge或clear从Kusto表中删除数据吗？ 我无法使用azure-kusto-data或azure-kusto-ingest包实现数据删除。有没有办法做到这一点？
浏览 21提问于2021-01-24得票数 1
回答已采纳
2回答
我的项目主要由azure函数和Kusto组成。大多数处理都是在Kusto中完成的，包括不同的表、使用不同Kusto函数的更新策略、物化视图等。我如何在Visio中表示所有这些功能？我找不到任何相关的例子。
浏览 56提问于2021-06-26得票数 1
回答已采纳
我正在使用内置连接器从Azure data摄取数据到ADX .我有许多管道和数据流成功地输出到ADX，没有问题。另外，导致我出现问题的数据流一直工作得很好，直到最近进行了一次更改(我对类似的数据流进行了修改，没有问题)，当我检查发送到ADX的数据时，这看起来很好。
在最近的改变后，摄入过程停止，并可以坐着等待未完成的时间，直到取消为止.到达超时后，我在Azure Data中收到以下错误。
> Operation on target SWANTEL OS and Site Mapping failed: {"StatusCode":"DFExecutorUs
浏览 13提问于2022-07-26得票数 1
我在下面创建了一个简单的函数MaterializeRemoteInputTable，它接受表的输出作为输入。为了测试输入是否物化，我使用它两次计算两个标量值-x和y：
.create-or-alter function MaterializeRemoteInputTable(inputTable: (State:string)) {
let materializedInput = materialize(inputTable);
let x = toscalar(materializedInput | count );
let y = toscalar(materializedInput |
浏览 5提问于2022-04-30得票数 0
回答已采纳
我有一个where条件，我想在我的Azure Data Explorer DB中运行一组表。我发现Kusto查询中的"Find in ()“运算符非常有用，当我按照预期传递表列表时，它工作得很好。
find withsource=DataType in (AppServiceFileAuditLogs,AzureDiagnostics)
where TimeGenerated > ago(31d)
project _ResourceId, _BilledSize, _IsBillable
| where _IsBillable == true
| summarize Bill
浏览 4提问于2021-05-27得票数 0
回答已采纳
我正在做自动化创建adx kusto集群创建使用python与azure cli模块。我可以创建一个具有指定容量的集群。但我不知道如何实现自动缩放放大/缩小。如何在python中实现？
if get_default_cli().invoke(['kusto', 'cluster', 'create', '--name', name, '--sku', sku, '--resource-group', resource_group, '--capacity', capacity]) =
浏览 4提问于2019-08-29得票数 1
3回答
如何连接2个没有任何链接的不同表 表1-库存(有商店的所有商品) 表2-销售额 现在，我需要一个文件中的表1和表2中的数据 ItemCode SOH_Quantity
aaaaaaaa 10
bbbbbbbb 12
cccccccc 20 表2 ItemCode Quantity InvoiceNo Date
aaaaaaaa 1 001 25/01/2021 我需要以下输出 ItemCode Quantity Type
aaaaaaaa 10 I
bbbbbbbb 12 I
cccccccc 20 I
aaaaaaaa
浏览 20提问于2021-01-25得票数 1
1回答
我正在使用azure.kusto.ingest.QueuedIngestClient通过ingest_from_dataframe方法将熊猫DataFrames摄入到表中。
client = QueuedIngestClient(...)
df = pd.DataFrame(...)
response = client.ingest_from_dataframe(df, ...)
response是azure.kusto.ingest.base_ingest_client.IngestionResult类型的，有一个属性status。但是，即使在摄入完成后(通过对DB的查询手动检查)，它也始终
浏览 9提问于2022-11-18得票数 0
回答已采纳
1回答
如何在Kusto中运行计划函数？
、、、、
我有一个Kusto表，它有传入的流数据。但是，我需要将每天的汇总存储在另一个表中。是否有一种方法可以在Kusto中运行调度函数，例如在午夜运行并将结果吸收到聚合表中？如果没有，我怎样才能达到我的目标？是否有可用的连接器可以实现这一点？
浏览 5提问于2021-06-21得票数 1
回答已采纳
我有一个项目，其中大部分是在Kusto完成的。我想知道上传Kusto表模式和我开发的函数到git的最好方法是什么，以便其他人可以查看它。创建一个文本文件并复制所有的表创建命令、更新策略和函数代码就足够了吗?还有其他更好的方法吗？
浏览 19提问于2021-06-22得票数 1
回答已采纳
1回答
I在Kusto表中有下面的数据。( Run_Date datetime和传感器字符串是表中的两列)
我需要以这样的方式添加自动增量列，如果运行日期或传感器值被更改，列应该增加一个。
请参阅附呈的截图。我试过用kusto的Rank和Rownumber函数，但对我来说没有运气。
浏览 1提问于2021-08-15得票数 0
1回答
我有一个表，其中包含项目和他们的变化价格取决于日期。
gold 12-jan $400
gold 15-jan $440
silv 13-jan $100
silv 10-jan $090
我需要一个kusto查询，可以为我带来的项目和它的最新价格。所以输出是：
gold 15-jan $440
silv 13-jan $100
浏览 0提问于2020-02-03得票数 0
我正在尝试转换从运行Kusto查询(在其中检索表的架构)中收到的响应。我的Kusto查询如下：
tableName | getschema
这种查询的响应，如Kusto中所示，如下所示(不完整)
回到我的C#代码中，我定义了以下类：
public class DatasetColumn
{
/// <summary>
/// Name of the column
/// </summary>
public string? ColumnName { get; set; }
浏览 11提问于2022-07-14得票数 2
回答已采纳
了解更多关于如何用Kusto编写查询的信息。我在两个具有不同角色的表中有一列，但列标题是Role，我想将数据组合到一个名为Roles的列中。 我尝试添加了这个| extend Roles = strcat (RoleName，Role)，但这只是合并了数据。 这是我的查询尝试，我连接了3个表，其中2个表具有角色。第三个是我验证用户别名的地方。 (cluster('****').database('****').****_****** | where Discriminator == 'Service'| where DivisionOid ==
浏览 61提问于2019-06-28得票数 2
我正在优化一些Kusto代码，在这些代码中，对基表的访问被封装在用户定义的函数中，有时是几层函数调用。例如，假设您有一个表格函数GetStuff()，它反过来调用一个表格函数GetStuff2()，后者调用基本的Kusto表内容。我的问题是:如果我编写一个Kusto查询，其中包含一个与表格函数GetStuff()的连接，那么Azure Data Explorer优化器会优化所涉及的整个调用堆栈吗？换句话说，它的行为会像关系数据库中的视图一样，首先分解视图定义，为整个查询创建和优化查询计划，还是只在函数定义或查询级别进行优化？ .create-or-alter function with (f
浏览 10提问于2019-06-20得票数 1
我试图使用ADF完成从Azure Devops到Azure Kusto集群的增量加载。由于Kusto没有更新或删除特定记录的选项，我按照以下步骤实现增量数据加载。
数据将第一次作为满载加载到主表(表A)中。
我将从表A获得最大修改日期，并且只使用以下过滤器将最新修改的数据加载到库斯托的TableStg中。(>=(最大修改日期-1天)
我将在Kusto中创建一个临时表(TableTemp)，将修改后的/新数据(来自TableStg)合并到单个表中，然后使用下面的KQL将主表(表A)替换为临时表。
.set-or-replace TableTemp with (dist
浏览 1提问于2020-12-19得票数 0
Kusto (ADX)有.export命令将数据从Kusto导出到其他数据存储(不过，Azure存储是我特别感兴趣的)。这里我不是指持续出口，而是指出口命令，它也可以按需使用。我认为，几年前，这是唯一(开箱即用)的选择，可以从库斯托输出数据。现在，我看到ADFv2 (Azure Data Factory v2) 复制活动也支持ADX ( Kusto )作为源之一，使用它我们可以将数据从Kusto复制到Azure存储。但是哪种方法更快呢？有什么建议吗？我们还可以从ADFv2 2的ADX命令活动中编排.export命令--这就是我们之前所做的--但现在我看到，来自ADFv2的copy activi
浏览 6提问于2021-05-15得票数 0
回答已采纳
这里是以kusto为单位的数据集，我正在尝试根据release值生成"releaseRank“列。输入数据集：
let T = datatable(release:string, metric:long)
[
"22.05", 20,
"22.04", 40,
"22.03", 50,
"22.01", 560
];
T
|take 100;
期望产出：
发现存在序列化和row_number kusto
T
|serialize
|extend releaseRank = row_number()
|take
浏览 4提问于2022-06-13得票数 1
回答已采纳
我在Azure blob中有ORC数据文件，我想通过创建外部表从ADX集群读取这些数据。但是，在创建外部表时，我们似乎不能将orc指定为dataformat。它似乎只接受TSV，CSV，JSON，地板。有什么解决办法吗？
更新：
正如您在下面的屏幕截图中所看到的，当我试图创建一个外部表时，Kusto并没有将ORC显示为选项之一。现在，我打算使用这个外部表来读取(查询)外部数据，而不是真正的导出--但我想Kusto不会知道我的意图。
浏览 13提问于2021-06-23得票数 1
回答已采纳
我想创建一个表，其名称来自查询的结果。任何一个非常基本的例子都可以。结果可以是单个列，也可以是单个行。我只需要一个基本的例子，这样我就可以根据我的需求来调整和修改它。
浏览 1提问于2019-03-22得票数 1
1回答
我们有一个使用表名并对columns.This方法进行操作的方法，该方法以前使用MySQL，但在postgres中将空表名称作为表名。
下面我提供了一个非常简单的SQL查询，只是为了演示一下。
select * from ((select * from users2 limit 1)
union (select * from users limit 1)) as sub;
演示获取表名的代码。
try{
connection = DriverManager.getConnection(
connectionURL, dbUserName,
浏览 1提问于2016-01-04得票数 3
回答已采纳
1回答
我有一个数据库，其中有大约10个不同的表，我想在一个.dtsx包中导入。我可以在没有问题的情况下导入一个单独的表，我的问题是我不知道如何设置它来迭代这些表。我知道这将是一个foreach循环，但是哪种类型，以及如何指定表？有人能帮忙吗？
编辑--我是用数据流任务导入单个表。去Ole DB源--到-- Ole DB目的地。(来自Microsoft Access SQL Server)
编辑#2 -如何设置我的SQL语句来从多个表中提取数据？我想这就是SQL语句的去处。
浏览 1提问于2014-09-04得票数 1
回答已采纳
1回答
我有一个Kusto查询，它返回一系列行，每个行都包含一个分号分隔列表。我已经能够将每一行的内容分割成一个列表，但是我还无法将该列表扁平化。不幸的是，我对使用Kusto非常陌生，所以我有点挣扎。
我尝试使用函数"union“、"join”、"flatten“，并查找包含单词"merge”或“select多”的函数(在c#中，我将使用这个函数在linq中扁平)。我也尝试过搜索类似的sql函数，所以我可以在Kusto中查找类似的查询，但是我没有任何运气。
我使用的查询：
| where Nicknames != ""
| project split(N
浏览 0提问于2019-07-31得票数 3
回答已采纳
我有一个包含id:int和name:string字段的kusto表，其中包含数据。我试图将id: int的表模式类型更改为id:long。我试了下，但它抛出了下面的错误。我也尝试了.alter，而不是. tried，但是没有成功。用数据更新现有表的Kusto表列类型的过程是什么，同时不干扰当前数据？
.alter-merge table mytable
(Id: long, Name: string)
错误：“Alter不支持现有列(Id)的列数据类型更改。当前的type=I32，请求的类型=I64”。
浏览 1提问于2021-01-27得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
