GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-07-07 07:21:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

docs: add perf monitor in example

Browse Source
This commit is contained in:
debugtalk
2022-11-25 22:36:39 +08:00
parent 1dee4131b0
commit 037b7f0190
2 changed files with 29 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
examples/worldcup/cli.go
View File

@@ -35,6 +35,7 @@ var (
interval int interval int
logLevel string logLevel string
matchName string matchName string
perf []string
) )
func main() { func main() {
@@ -44,6 +45,8 @@ func main() {
rootCmd.PersistentFlags().IntVarP(&duration, "duration", "d", 30, "set duration in seconds") rootCmd.PersistentFlags().IntVarP(&duration, "duration", "d", 30, "set duration in seconds")
rootCmd.PersistentFlags().IntVarP(&interval, "interval", "i", 15, "set interval in seconds") rootCmd.PersistentFlags().IntVarP(&interval, "interval", "i", 15, "set interval in seconds")
rootCmd.PersistentFlags().StringVarP(&matchName, "match-name", "n", "", "specify match name") rootCmd.PersistentFlags().StringVarP(&matchName, "match-name", "n", "", "specify match name")
rootCmd.PersistentFlags().StringSliceVarP(&perf, "perf", "p", nil,
"specify performance monitor, e.g. sys_cpu,sys_mem,sys_net,sys_disk,fps,network,gpu")
err := rootCmd.Execute() err := rootCmd.Execute()
if err != nil { if err != nil {

28
examples/worldcup/main.go
View File

@@ -13,6 +13,8 @@ import (
"github.com/rs/zerolog/log" "github.com/rs/zerolog/log"
"github.com/httprunner/httprunner/v4/hrp"
"github.com/httprunner/httprunner/v4/hrp/pkg/gidevice"
"github.com/httprunner/httprunner/v4/hrp/pkg/uixt" "github.com/httprunner/httprunner/v4/hrp/pkg/uixt"
) )
@@ -35,11 +37,31 @@ func convertTimeToSeconds(timeStr string) (int, error) {
} }
func initIOSDevice() uixt.Device { func initIOSDevice() uixt.Device {
perfOptions := []gidevice.PerfOption{}
for _, p := range perf {
switch p {
case "sys_cpu":
perfOptions = append(perfOptions, hrp.WithPerfSystemCPU(true))
case "sys_mem":
perfOptions = append(perfOptions, hrp.WithPerfSystemMem(true))
case "sys_net":
perfOptions = append(perfOptions, hrp.WithPerfSystemNetwork(true))
case "sys_disk":
perfOptions = append(perfOptions, hrp.WithPerfSystemDisk(true))
case "network":
perfOptions = append(perfOptions, hrp.WithPerfNetwork(true))
case "fps":
perfOptions = append(perfOptions, hrp.WithPerfFPS(true))
case "gpu":
perfOptions = append(perfOptions, hrp.WithPerfGPU(true))
}
}
device, err := uixt.NewIOSDevice( device, err := uixt.NewIOSDevice(
uixt.WithUDID(uuid), uixt.WithUDID(uuid),
uixt.WithWDAPort(8700), uixt.WithWDAMjpegPort(8800), uixt.WithWDAPort(8700), uixt.WithWDAMjpegPort(8800),
uixt.WithResetHomeOnStartup(false), // not reset home on startup uixt.WithResetHomeOnStartup(false), // not reset home on startup
// uixt.WithPerfOptions(), uixt.WithPerfOptions(perfOptions...),
) )
if err != nil { if err != nil {
log.Fatal().Err(err).Msg("failed to init ios device") log.Fatal().Err(err).Msg("failed to init ios device")
@@ -73,6 +95,7 @@ type WorldCupLive struct {
Interval int `json:"interval"` // seconds Interval int `json:"interval"` // seconds
Duration int `json:"duration"` // seconds Duration int `json:"duration"` // seconds
Summary []timeLog `json:"summary"` Summary []timeLog `json:"summary"`
PerfData []string `json:"perfData"`
} }
func NewWorldCupLive(matchName, osType string, duration, interval int) *WorldCupLive { func NewWorldCupLive(matchName, osType string, duration, interval int) *WorldCupLive {
@@ -145,7 +168,7 @@ func (wc *WorldCupLive) getCurrentLiveTime(utcTime time.Time) error {
liveTimeSeconds = seconds liveTimeSeconds = seconds
line := fmt.Sprintf("%s\t%d\t%s\t%d\n", line := fmt.Sprintf("%s\t%d\t%s\t%d\n",
utcTimeStr, utcTime.Unix(), ocrText.Text, liveTimeSeconds) utcTimeStr, utcTime.Unix(), ocrText.Text, liveTimeSeconds)
fmt.Print(line) log.Info().Str("utcTime", utcTimeStr).Str("liveTime", ocrText.Text).Msg("log live time")
if _, err := wc.file.WriteString(line); err != nil { if _, err := wc.file.WriteString(line); err != nil {
log.Error().Err(err).Str("line", line).Msg("write timeseries failed") log.Error().Err(err).Str("line", line).Msg("write timeseries failed")
} }
@@ -193,6 +216,7 @@ func (wc *WorldCupLive) DumpResult() error {
encoder.SetEscapeHTML(false) encoder.SetEscapeHTML(false)
encoder.SetIndent("", " ") encoder.SetIndent("", " ")
wc.PerfData = wc.driver.GetPerfData()
err := encoder.Encode(wc) err := encoder.Encode(wc)
if err != nil { if err != nil {
return err return err