Skip to content

{Storage} Enable logging for track2 data plane operations #16439

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Juliehzl merged 3 commits into from
Jan 13, 2021
Merged

{Storage} Enable logging for track2 data plane operations #16439

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e65db24
config log
Juliehzl Jan 7, 2021
8b43e19
use common function
Juliehzl Jan 9, 2021
7d77650
refine
Juliehzl Jan 12, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
refine
  • Loading branch information
@Juliehzl
Juliehzl committed Jan 12, 2021
commit 7d776504a824ea095d2aa3f6f9d5f81f256b753e
9 changes: 3 additions & 6 deletions src/azure-cli/azure/cli/command_modules/storage/_client_factory.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ def get_account_url(cli_ctx, account_name, service):

def cf_blob_service(cli_ctx, kwargs):
from knack.util import CLIError
client_kwargs = {}
client_kwargs = _prepare_client_kwargs_track2(cli_ctx)
t_blob_service = get_sdk(cli_ctx, ResourceType.DATA_STORAGE_BLOB,
'_blob_service_client#BlobServiceClient')
connection_string = kwargs.pop('connection_string', None)
Expand All @@ -206,7 +206,6 @@ def cf_blob_service(cli_ctx, kwargs):
token_credential = kwargs.pop('token_credential', None)
sas_token = kwargs.pop('sas_token', None)

client_kwargs.update(_prepare_client_kwargs_track2(cli_ctx))
if connection_string:
try:
return t_blob_service.from_connection_string(conn_str=connection_string, **client_kwargs)
Expand Down Expand Up @@ -244,7 +243,7 @@ def cf_container_client(cli_ctx, kwargs):


def cf_adls_service(cli_ctx, kwargs):
client_kwargs = {}
client_kwargs = _prepare_client_kwargs_track2(cli_ctx)
t_adls_service = get_sdk(cli_ctx, ResourceType.DATA_STORAGE_FILEDATALAKE,
'_data_lake_service_client#DataLakeServiceClient')
connection_string = kwargs.pop('connection_string', None)
Expand All @@ -253,7 +252,6 @@ def cf_adls_service(cli_ctx, kwargs):
token_credential = kwargs.pop('token_credential', None)
sas_token = kwargs.pop('sas_token', None)

client_kwargs.update(_prepare_client_kwargs_track2(cli_ctx))
if connection_string:
return t_adls_service.from_connection_string(conn_str=connection_string, **client_kwargs)

Expand Down Expand Up @@ -284,15 +282,14 @@ def cf_or_policy(cli_ctx, _):

def cf_queue_service(cli_ctx, kwargs):
from knack.util import CLIError
client_kwargs = {}
client_kwargs = _prepare_client_kwargs_track2(cli_ctx)
t_queue_service = get_sdk(cli_ctx, ResourceType.DATA_STORAGE_QUEUE, '_queue_service_client#QueueServiceClient')
connection_string = kwargs.pop('connection_string', None)
account_name = kwargs.pop('account_name', None)
account_key = kwargs.pop('account_key', None)
token_credential = kwargs.pop('token_credential', None)
sas_token = kwargs.pop('sas_token', None)

client_kwargs.update(_prepare_client_kwargs_track2(cli_ctx))
if connection_string:
return t_queue_service.from_connection_string(conn_str=connection_string, **client_kwargs)

Expand Down