async def METHOD_NAME(self, account_name, account_key):
    url = self.account_url(account_name, 'dfs')
    self.payload_dropping_policy = PayloadDroppingPolicy()
    credential_policy = _format_shared_key_credential(account_name, account_key)
    self.dsc = DataLakeServiceClient(url,
                                     credential=account_key,
                                     _additional_pipeline_policies=[self.payload_dropping_policy, credential_policy])
    self.config = self.dsc._config
    self.file_system_name = self.get_resource_name('filesystem')
    if not self.is_playback():
        file_system = self.dsc.get_file_system_client(self.file_system_name)
        try:
            await file_system.create_file_system(timeout=5)
        except ResourceExistsError:
            pass