azure-batch-apps 0.5.2

应用程序配置

以便与批处理应用程序中在服务中设置的应用程序交互 帐户，您将需要配置python客户端。

当您第一次实例化配置对象时， 文件将默认创建为：

$HOME/BatchAppsData/batch_apps.ini

单个配置对象表示批处理应用程序帐户中的单个服务。 这意味着每个配置都需要一个端点和客户端ID。

要设置新的作业类型引用，可以将其添加到配置文件中， 以及您希望与之关联的任何自定义参数。

您可以直接编辑文件，也可以通过配置类进行编辑：

from batchapps import Configuration

# These can be retrieved when creating an unattended account in the Batch Apps portal.
# See the authentication section below for more details.
endpoint = 'myservice.batchapps.core.windows.net'
account_details = 'ClientID=xxxxxxxx;TenantID=abcdefg'
account_key = '12345'

cfg = Configuration(log_level='debug', default=True)
cfg.aad_config(account=account_details, key=account_key,
        endpoint=endpoint, unattended=True)

cfg.add_jobtype('my_job_type')

# Set this job type as the current job type
cfg.current_jobtype('my_job_type')

# Set the current job type as the default job type for future jobs
cfg.set_default_jobtype()

# Set up some default parameter values for the current job type
cfg.set('quality', 10)
cfg.set('timeout', 500)

# Save updated configuration to file
cfg.save_config()

认证

模块使用azure活动目录（oauth2的实现）进行身份验证。 BatchApps模块提供了一个帮助程序类来帮助检索AAD令牌 使用请求oauthlib。但是，如果您有一个首选的oauth实现，那么 可以改为使用此进行身份验证。

您可以在 Batch Apps account。这些将在 格式：

Account Id = ClientId=abc;TenantId=xyz
Account Key = ***********************

一旦您有了这些凭据，就可以通过添加 它们可以使用python进行batch_apps.ini配置，如上所述， 或者直接编辑文件：

[Authentication]
endpoint = myservice.batchapps.core.windows.net
unattended_account = ClientID=abc;TenantID=xyz
unattended_key = ***********************

然后您可以使用这些凭据进行身份验证：

from batchapps import AzureOAuth

creds = AzureOAuth.get_unattended_session()

或者，如果你使用D检索令牌的不同aad实现：

from batchapps import Credentials, Configuration
import my_oauth

client_id = "abc"
cfg = Configuration()

aad_token = my_oauth.get_token(client_id)
creds = Credentials(cfg, client_id, token=aad_token)

不久将支持通过登录到web ui进行身份验证。

工作管理

完成作业管理，包括提交、监控和访问输出 通过JobManager类：

from batchapps import AzureOAuth, JobManager
import time

creds = AzureOAuth.get_unattended_session()
mgr = JobManager(creds)

my_job = mgr.create_job("First Job")

# Apply any custom parameters and source files here
my_job.example_parameter = "test123"

# Then submit the job
new_job = my_job.submit()

job_progress = mgr.get_job(url=new_job['link'])

# Let's allow up to 30 minutes for the job to complete
timeout = time.time() + 1800

while time.time() < timeout:

        if job_progress.status is 'Complete':
                job_progress.get_output('c:\\my_download_dir')
                break

        if job_progress.status is 'Error':
                break

        time.sleep(30)
        job_progress.update()

else:
        job_progress.cancel()

文件管理

文件管理，包括将作业源文件和依赖项同步到 云可以使用filemanager类来完成：

from batchapps import AzureOAuth, FileManager

creds = AzureOAuth.get_unattended_session()
mgr = FileManager(creds)

file_collection = mgr.files_from_dir('c:\\my_job_assets')
job_source = mgr.file_from_path('C:\\start_job.bat')
file_collection.add(job_source)

file_collection.upload()

# Check files previously uploaded matching a certain name
mgr.find_files('start_job.bat')

# Retrieve a list of all uploaded files
mgr.list_files()

泳池管理

池管理，包括创建、调整大小和删除池 使用poolmanager类完成。

创建池后，可以向池提交作业。默认情况下， 当一个作业提交而不引用现有的池时，它将 使用将为运行作业创建的自动池，然后 完成时删除：

from batchapps import AzureOAuth, PoolManager

creds = AzureOAuth.get_unattended_session()
mgr = PoolManager(creds)

new_pool = mgr.create_pool(target_size=5)

# Create new job submission, then submit to pool
my_job.pool = new_pool
my_job.submit()

# After job has completed, and we no longer need the pool
pool.delete()