无法在数据工厂上创建变量 Activity
Cannot Create Variable Activity on data Factory
我正在尝试使用 python 创建数据工厂资源,但在调用几个 类
时出现错误
示例-我在这里尝试创建 "Set Variable Activity" 但出现错误
错误信息
NameError: name 'SetVariableActivity' is not defined
代码
from azure.mgmt.datafactory.models import *
variable_name = 'vGetDate'
var_activity = SetVariableActivity(name = 'Get Date',variable_name= variable_name, value = '@utcnow()' )
我也收到 DatasetFolder Class 的 NameError。我不确定出了什么问题,我以为我已经导入了所有必需的库并且我在 3.7 v
上使用
非常感谢任何意见。
我测试了我这边的代码,它工作正常,请尝试与我相同版本的库。
azure-common==1.1.23
azure-mgmt-datafactory==0.9.0
我的示例使用 Set variable
activity:
创建了一个管道
from azure.common.credentials import ServicePrincipalCredentials
from azure.mgmt.datafactory import DataFactoryManagementClient
from azure.mgmt.datafactory.models import *
subscription_id = '<subscription-id>'
credentials = ServicePrincipalCredentials(client_id='<client-id>', secret='<client-secret>', tenant='<tenant-id>')
adf_client = DataFactoryManagementClient(credentials, subscription_id)
variable_name = 'vGetDate'
var_activity = SetVariableActivity(name = 'Get Date',variable_name= variable_name, value = '@utcnow()' )
rg_name = '<resource-group-name>'
df_name = 'joyfactory'
p_name = 'Pipeline123'
params_for_pipeline = {}
p_obj = PipelineResource(
activities=[var_activity], parameters=params_for_pipeline)
p = adf_client.pipelines.create_or_update(rg_name, df_name, p_name, p_obj)
print(p)
登陆门户:
我正在尝试使用 python 创建数据工厂资源,但在调用几个 类
时出现错误示例-我在这里尝试创建 "Set Variable Activity" 但出现错误
错误信息
NameError: name 'SetVariableActivity' is not defined
代码
from azure.mgmt.datafactory.models import *
variable_name = 'vGetDate'
var_activity = SetVariableActivity(name = 'Get Date',variable_name= variable_name, value = '@utcnow()' )
我也收到 DatasetFolder Class 的 NameError。我不确定出了什么问题,我以为我已经导入了所有必需的库并且我在 3.7 v
上使用非常感谢任何意见。
我测试了我这边的代码,它工作正常,请尝试与我相同版本的库。
azure-common==1.1.23
azure-mgmt-datafactory==0.9.0
我的示例使用 Set variable
activity:
from azure.common.credentials import ServicePrincipalCredentials
from azure.mgmt.datafactory import DataFactoryManagementClient
from azure.mgmt.datafactory.models import *
subscription_id = '<subscription-id>'
credentials = ServicePrincipalCredentials(client_id='<client-id>', secret='<client-secret>', tenant='<tenant-id>')
adf_client = DataFactoryManagementClient(credentials, subscription_id)
variable_name = 'vGetDate'
var_activity = SetVariableActivity(name = 'Get Date',variable_name= variable_name, value = '@utcnow()' )
rg_name = '<resource-group-name>'
df_name = 'joyfactory'
p_name = 'Pipeline123'
params_for_pipeline = {}
p_obj = PipelineResource(
activities=[var_activity], parameters=params_for_pipeline)
p = adf_client.pipelines.create_or_update(rg_name, df_name, p_name, p_obj)
print(p)
登陆门户: