Skip to content

Pytest sample stream #2660

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
wangxin merged 10 commits into from
Jan 5, 2021
Merged

Pytest sample stream #2660

Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
479e2cd
Adding PyTest for osversion/build query
Nov 24, 2020
9c3ec92
Merged with master
Nov 24, 2020
961db9b
Basic PyTest for streaming mode
Dec 2, 2020
881aecc
Processing PR comments.
Dec 2, 2020
6085b54
Merge branch 'pytest-build-version' into pytest-sample-stream
Dec 2, 2020
1af50d6
rebasing with upstream
Dec 14, 2020
7bc87ae
Rebased with upstream
Dec 14, 2020
c45f5c9
Merge branch 'master' into pytest-sample-stream
Dec 15, 2020
6c2a7d4
Merge branch 'master' into pytest-sample-stream
Dec 22, 2020
079b83b
Resolving comments.
Dec 22, 2020
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
16 changes: 14 additions & 2 deletions tests/telemetry/test_telemetry.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -167,9 +167,7 @@ def test_osbuild_version(duthosts, rand_one_dut_hostname, ptfhost, localhost):
"""
duthost = duthosts[rand_one_dut_hostname]
cmd = generate_client_cli(duthost=duthost, method=METHOD_GET, target="OTHERS", xpath="osversion/build")
logger.debug("Command to run: {0}".format(cmd))
show_gnmi_out = ptfhost.shell(cmd)['stdout']
logger.debug(show_gnmi_out)
result = str(show_gnmi_out)

assert_equal(len(re.findall('"build_version": "sonic\.', result)), 1, "build_version value at {0}".format(result))
Expand Down Expand Up @@ -218,3 +216,17 @@ def test_sysuptime(duthosts, rand_one_dut_hostname, ptfhost, setup_streaming_tel

if system_uptime_2nd - system_uptime_1st < 10:
pytest.fail("The value of system uptime was not updated correctly.")

def test_virtualdb_table_streaming(duthosts, rand_one_dut_hostname, ptfhost, localhost):
"""Run pyclient from ptfdocker to stream a virtual-db query multiple times.
"""
logger.info('start virtual db sample streaming testing')

duthost = duthosts[rand_one_dut_hostname]
cmd = generate_client_cli(duthost=duthost, method=METHOD_SUBSCRIBE, update_count = 3)
show_gnmi_out = ptfhost.shell(cmd)['stdout']
result = str(show_gnmi_out)

assert_equal(len(re.findall('Max update count reached 3', result)), 1, "Streaming update count in:\n{0}".format(result))
assert_equal(len(re.findall('name: "Ethernet0"\n', result)), 4, "Streaming updates for Ethernet0 in:\n{0}".format(result)) # 1 for request, 3 for response
assert_equal(len(re.findall('timestamp: \d+', result)), 3, "Timestamp markers for each update message in:\n{0}".format(result))