我有一组现有的天蓝色存储表,每个客户端一个,用于在多租户云系统中保存事件。
例如,可能有 3 个表来保存登录信息:
ClientASignins ClientBSignins ClientCSignins
有没有办法动态循环这些作为复制操作的一部分或像 Pig 脚本一样?
还是有其他方法可以达到这个结果?
非常感谢!
我有一组现有的天蓝色存储表,每个客户端一个,用于在多租户云系统中保存事件。
例如,可能有 3 个表来保存登录信息:
ClientASignins ClientBSignins ClientCSignins
有没有办法动态循环这些作为复制操作的一部分或像 Pig 脚本一样?
还是有其他方法可以达到这个结果?
非常感谢!
如果您在其他位置(如 Azure 存储)跟踪这些表,则可以使用 PowerShell 循环遍历它们并在每个位置上创建一个配置单元表。例如:
foreach($t in $tableList) {
$hiveQuery = "CREATE EXTERNAL TABLE $t(IntValue int)
STORED BY 'com.microsoft.hadoop.azure.hive.AzureTableHiveStorageHandler'
TBLPROPERTIES(
""azure.table.name""=""$($t.tableName)"",
""azure.table.account.uri""=""http://$storageAccount.table.core.windows.net"",
""azure.table.storage.key""=""$((Get-AzureStorageKey $storageAccount).Primary)"");"
Out-File -FilePath .\HiveCreateTable.q -InputObject $hiveQuery -Encoding ascii
$hiveQueryBlob = Set-AzureStorageBlobContent -File .\HiveCreateTable.q -Blob "queries/HiveCreateTable.q" `
-Container $clusterContainer.Name -Force
$createTableJobDefinition = New-AzureHDInsightHiveJobDefinition -QueryFile /queries/HiveCreateTable.q
$job = Start-AzureHDInsightJob -JobDefinition $createTableJobDefinition -Cluster $cluster.Name
Wait-AzureHDInsightJob -Job $job
#INSERT YOUR OPERATIONS FOR EACH TABLE HERE
}
最后,我选择了几个用 c# 编写的 Azure 数据工厂自定义活动,现在我的工作流程是:
我这样做是为了使管道尽可能简单,并消除对管道/脚本的任何重复的需要。
参考: