NameError: имя 'self' не определено в <script>в строке номер 6 - PullRequest
Новая
       3

NameError: имя 'self' не определено в <script>в строке номер 6

0 голосов
/ 26 мая 2020

Я новичок в python и пытаюсь написать код, который подключается к ir c серверу. Я ввожу код в процессор NiFi ExecuteScript и пытаюсь выполнить. При запуске я получаю сообщение об ошибке ниже. Я не уверен, что причиной проблемы является NiFi или просто сам код.

NameError: имя 'self' не определено в строке номер 6 

import socket
from org.apache.nifi.processor.io import StreamCallback

class PyStreamCallback(StreamCallback):
  def __init__(self):
    pass
  self.ircsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  self.server = "irc.freenode.net"
  self.channel = ""
  self.botnick = ""
  self.ircsock.connect((server, 6667))
  self.ircsock.send(bytes("USER "+ botnick +" "+ botnick +" "+ botnick + " " + botnick + "\n"))
  self.ircsock.send(bytes("NICK "+ botnick +"\n"))

  def joinchan(self, chan):
    self.ircsock.send(bytes("JOIN "+ chan +"\n"))
    ircmsg = ""
    while ircmsg.find("End of /NAMES list.") == -1:
      self.ircmsg = ircsock.recv(2048)
      self.ircmsg = ircmsg.strip('\n\r')
      print(ircmsg)

  def ping(self):
    self.ircsock.send(bytes("PONG :pingis\n"))

  def sendmsg(self, msg, target=channel):
    self.ircsock.send(bytes("PRIVMSG "+ target +" :"+ msg +"\n"))



flowFile = session.get()
if (flowFile != None):
  flowFile = session.write(flowFile,PyStreamCallback())
  session.transfer(flowFile, REL_SUCCESS)
session.commit()

1 Ответ

1 голос
/ 26 мая 2020

Ваша функция инициализации имеет неправильный отступ 

class PyStreamCallback(StreamCallback): 
    def __init__(self):
        pass
        self.ircsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.server = "irc.freenode.net" 
        self.channel = "" self.botnick = ""
        self.ircsock.connect((server, 6667))
        self.ircsock.send(bytes("USER "+ botnick +" "+ botnick +" "+ botnick + " " + botnick + "\n")) 
        self.ircsock.send(bytes("NICK "+ botnick +"\n"))
    ...
...